org.openhubframework.openhub.component.asynchchild

Class AsynchChildProducer

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.impl.DefaultProducer

org.openhubframework.openhub.component.asynchchild.AsynchChildProducer

All Implemented Interfaces:

org.apache.camel.EndpointAware, org.apache.camel.IsSingleton, org.apache.camel.Processor, org.apache.camel.Producer, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class AsynchChildProducer
extends org.apache.camel.impl.DefaultProducer

Producer for asynch-child component.

Author:

Petr Juza

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_EXTERNAL_SYSTEM

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

log

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

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

Constructor Summary

Constructors

Constructor and Description
AsynchChildProducer(AsynchChildEndpoint endpoint) Creates new producer.

Method Summary

Methods

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.

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

createExchange, createExchange, createExchange, doStart, doStop, getEndpoint, isSingleton, 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

DEFAULT_EXTERNAL_SYSTEM

public static final String DEFAULT_EXTERNAL_SYSTEM

See Also:

Constant Field Values

Constructor Detail

AsynchChildProducer

public AsynchChildProducer(AsynchChildEndpoint endpoint)

Creates new producer.

Parameters:

endpoint - the endpoint

Method Detail

process

public final void process(org.apache.camel.Exchange exchange)
                   throws Exception

Throws:

Exception

generateCorrelationId

protected String generateCorrelationId()

Generates unique ID via UUID.randomUUID().

Returns:

unique ID

insertMessage

protected void insertMessage(Message msg)

Inserts new messages into DB.

Parameters:

msg - the message

getMessageService

protected MessageService getMessageService()

Gets MessageService instance from Camel Context.

Returns:

MessageService

Throws:

IllegalStateException - when there is no MessageService

sendForNextProcessing

protected void sendForNextProcessing(Message msg)

Sends message for next asynchronous processing.

Parameters:

msg - the message

getProducerTemplate

protected org.apache.camel.ProducerTemplate getProducerTemplate()

Gets ProducerTemplate default instance from Camel Context.

Returns:

ProducerTemplate

Throws:

IllegalStateException - when there is no ProducerTemplate