public class AsynchChildProducer
extends org.apache.camel.impl.DefaultProducer
asynch-child
component.Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_EXTERNAL_SYSTEM |
Constructor and Description |
---|
AsynchChildProducer(AsynchChildEndpoint endpoint)
Creates new producer.
|
Modifier and Type | Method and Description |
---|---|
protected String |
generateCorrelationId()
Generates unique ID via
UUID.randomUUID() . |
protected MessageService |
getMessageService()
Gets
MessageService instance from Camel Context. |
protected org.apache.camel.ProducerTemplate |
getProducerTemplate()
Gets
ProducerTemplate default instance from Camel Context. |
protected void |
insertMessage(Message msg)
Inserts new messages into DB.
|
void |
process(org.apache.camel.Exchange exchange) |
protected void |
sendForNextProcessing(Message msg)
Sends message for next asynchronous processing.
|
createExchange, createExchange, createExchange, doStart, doStop, getEndpoint, isSingleton, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public static final String DEFAULT_EXTERNAL_SYSTEM
public AsynchChildProducer(AsynchChildEndpoint endpoint)
endpoint
- the endpointpublic final void process(org.apache.camel.Exchange exchange) throws Exception
Exception
protected String generateCorrelationId()
UUID.randomUUID()
.protected void insertMessage(Message msg)
msg
- the messageprotected MessageService getMessageService()
MessageService
instance from Camel Context.IllegalStateException
- when there is no MessageServiceprotected void sendForNextProcessing(Message msg)
msg
- the messageprotected org.apache.camel.ProducerTemplate getProducerTemplate()
ProducerTemplate
default instance from Camel Context.IllegalStateException
- when there is no ProducerTemplateCopyright © 2018 Pivotal Software, Inc.. All rights reserved.