public class PostIngestConsumer extends org.apache.camel.impl.DefaultConsumer implements PostIngestPlugin
Modifier and Type | Field and Description |
---|---|
static String |
ACTION |
static String |
CREATE |
static String |
DELETE |
static String |
UPDATE |
Constructor and Description |
---|
PostIngestConsumer(CatalogEndpoint endpoint,
org.apache.camel.Processor processor) |
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 . |
createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public static final String CREATE
public static final String UPDATE
public static final String DELETE
public static final String ACTION
public PostIngestConsumer(CatalogEndpoint endpoint, org.apache.camel.Processor processor)
public CreateResponse process(CreateResponse input) throws PluginExecutionException
PostIngestPlugin
CreateResponse
.process
in interface PostIngestPlugin
input
- the CreateResponse
to processCreateResponse
to pass to the next PostIngestPlugin
, or if this is the last PostIngestPlugin
to be calledPluginExecutionException
- thrown when an error occurs during processingpublic UpdateResponse process(UpdateResponse input) throws PluginExecutionException
PostIngestPlugin
UpdateResponse
.process
in interface PostIngestPlugin
input
- the UpdateResponse
to processUpdateResponse
to pass to the next PostIngestPlugin
, or if this is the last PostIngestPlugin
to be calledPluginExecutionException
- thrown when an error occurs during processingpublic DeleteResponse process(DeleteResponse input) throws PluginExecutionException
PostIngestPlugin
DeleteResponse
.process
in interface PostIngestPlugin
input
- the DeleteResponse
to processDeleteResponse
to pass to the next PostIngestPlugin
, or if this is the last PostIngestPlugin
to be calledPluginExecutionException
- thrown when an error occurs during processingprotected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultConsumer
Exception
This work is licensed under a Creative Commons Attribution 4.0 International License.