ddf.camel.component.catalog.ingest

Class PostIngestConsumer

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.impl.DefaultConsumer

ddf.camel.component.catalog.ingest.PostIngestConsumer

All Implemented Interfaces:

PostIngestPlugin, org.apache.camel.Consumer, org.apache.camel.EndpointAware, org.apache.camel.RouteAware, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class PostIngestConsumer
extends org.apache.camel.impl.DefaultConsumer
implements PostIngestPlugin

Camel Consumer Post Ingest plugin used to provide the responses passed to Post Ingest Plugins to camel routes.

Field Summary

Fields

Modifier and Type	Field and Description
static String	ACTION
static String	CREATE
static String	DELETE
static String	UPDATE

Fields inherited from class org.apache.camel.impl.DefaultConsumer

log

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

Constructors

Constructor and Description
PostIngestConsumer(CatalogEndpoint endpoint, org.apache.camel.Processor processor)

Method Summary

Modifier and Type	Method and Description
protected void	doStart()
protected void	doStop()
CreateResponse	process(CreateResponse input) Processes the CreateResponse.
DeleteResponse	process(DeleteResponse input) Processes the DeleteResponse.
UpdateResponse	process(UpdateResponse input) Processes the UpdateResponse.

Methods inherited from class org.apache.camel.impl.DefaultConsumer

createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.camel.Service

start, stop

Field Detail

CREATE

public static final String CREATE

See Also:

Constant Field Values

UPDATE

public static final String UPDATE

See Also:

Constant Field Values

DELETE

public static final String DELETE

See Also:

Constant Field Values

ACTION

public static final String ACTION

See Also:

Constant Field Values

Constructor Detail

PostIngestConsumer

public PostIngestConsumer(CatalogEndpoint endpoint,
                          org.apache.camel.Processor processor)

Method Detail

process

public CreateResponse process(CreateResponse input)
                       throws PluginExecutionException

Description copied from interface: PostIngestPlugin

Processes the CreateResponse.

Specified by:

process in interface PostIngestPlugin

Parameters:

input - the CreateResponse to process

Returns:

the value of the processed CreateResponse to pass to the next PostIngestPlugin, or if this is the last PostIngestPlugin to be called

Throws:

PluginExecutionException - thrown when an error occurs during processing

process

public UpdateResponse process(UpdateResponse input)
                       throws PluginExecutionException

Description copied from interface: PostIngestPlugin

Processes the UpdateResponse.

Specified by:

process in interface PostIngestPlugin

Parameters:

input - the UpdateResponse to process

Returns:

the value of the processed UpdateResponse to pass to the next PostIngestPlugin, or if this is the last PostIngestPlugin to be called

Throws:

PluginExecutionException - thrown when an error occurs during processing

process

public DeleteResponse process(DeleteResponse input)
                       throws PluginExecutionException

Description copied from interface: PostIngestPlugin

Processes the DeleteResponse.

Specified by:

process in interface PostIngestPlugin

Parameters:

input - the DeleteResponse to process

Returns:

the value of the processed DeleteResponse to pass to the next PostIngestPlugin, or if this is the last PostIngestPlugin to be called

Throws:

PluginExecutionException - thrown when an error occurs during processing

doStop

protected void doStop()
               throws Exception

Overrides:

doStop in class org.apache.camel.impl.DefaultConsumer

Throws:

Exception

doStart

protected void doStart()
                throws Exception

Overrides:

doStart in class org.apache.camel.impl.DefaultConsumer

Throws:

Exception