Package org.apache.camel.component.sjms.reply

Class ReplyManagerSupport

java.lang.Object

org.apache.camel.support.service.BaseService

org.apache.camel.support.service.ServiceSupport

org.apache.camel.component.sjms.reply.ReplyManagerSupport

All Implemented Interfaces:

AutoCloseable, ReplyManager, SessionMessageListener, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

Direct Known Subclasses:

QueueReplyManager, TemporaryQueueReplyManager

public abstract class ReplyManagerSupport
extends org.apache.camel.support.service.ServiceSupport
implements ReplyManager

Base class for ReplyManager implementations.

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.camel.CamelContext	camelContext
protected org.apache.camel.component.sjms.reply.CorrelationTimeoutMap	correlation
protected SjmsEndpoint	endpoint
protected ExecutorService	executorService
protected MessageListenerContainer	listenerContainer
protected org.slf4j.Logger	log
protected javax.jms.Destination	replyTo
protected CountDownLatch	replyToLatch
protected long	replyToTimeout
protected ScheduledExecutorService	scheduledExecutorService

Fields inherited from class org.apache.camel.support.service.BaseService

BUILT, FAILED, INITIALIZED, INITIALIZING, lock, NEW, SHUTDOWN, SHUTTING_DOWN, STARTED, STARTING, status, STOPPED, STOPPING, SUSPENDED, SUSPENDING

Constructor Summary

Constructors

Constructor	Description
ReplyManagerSupport(org.apache.camel.CamelContext camelContext)

Method Summary

Modifier and Type	Method	Description
protected abstract MessageListenerContainer	createListenerContainer()
protected void	doStart()
protected void	doStop()
javax.jms.Destination	getReplyTo()	Gets the reply to queue being used
protected abstract void	handleReplyMessage(String correlationID, javax.jms.Message message, javax.jms.Session session)
void	onMessage(javax.jms.Message message, javax.jms.Session session)
void	processReply(ReplyHolder holder)	Process the reply
String	registerReply(ReplyManager replyManager, org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback, String originalCorrelationId, String correlationId, long requestTimeout)	Register a reply
void	setEndpoint(SjmsEndpoint endpoint)	Sets the belonging SjmsEndpoint.
void	setOnTimeoutExecutorService(ExecutorService executorService)	Sets the thread pool to use for continue routing Exchange when a timeout was triggered when doing request/reply over JMS.
void	setReplyTo(javax.jms.Destination replyTo)	Sets the reply to queue the manager should listen for replies.
void	setScheduledExecutorService(ScheduledExecutorService executorService)	Sets the scheduled thread pool to use when checking for timeouts (no reply received within a given time period)

Methods inherited from class org.apache.camel.support.service.BaseService

build, doBuild, doFail, doInit, doLifecycleChange, doResume, doShutdown, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, 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, toString, wait, wait, wait

Methods inherited from interface org.apache.camel.component.sjms.reply.ReplyManager

updateCorrelationId

Methods inherited from interface org.apache.camel.Service

build, close, init, start, stop

Methods inherited from interface org.apache.camel.ShutdownableService

shutdown

Methods inherited from interface org.apache.camel.StatefulService

getStatus, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspending

Methods inherited from interface org.apache.camel.SuspendableService

isSuspended, resume, suspend

Field Detail

log

protected final org.slf4j.Logger log

camelContext

protected final org.apache.camel.CamelContext camelContext

scheduledExecutorService

protected ScheduledExecutorService scheduledExecutorService

executorService

protected ExecutorService executorService

endpoint

protected SjmsEndpoint endpoint

replyTo

protected javax.jms.Destination replyTo

listenerContainer

protected MessageListenerContainer listenerContainer

replyToLatch

protected final CountDownLatch replyToLatch

replyToTimeout

protected final long replyToTimeout

See Also:

Constant Field Values

correlation

protected org.apache.camel.component.sjms.reply.CorrelationTimeoutMap correlation

Constructor Detail

ReplyManagerSupport

public ReplyManagerSupport(org.apache.camel.CamelContext camelContext)

Method Detail

setScheduledExecutorService

public void setScheduledExecutorService(ScheduledExecutorService executorService)

Description copied from interface: ReplyManager

Sets the scheduled thread pool to use when checking for timeouts (no reply received within a given time period)

Specified by:

setScheduledExecutorService in interface ReplyManager

setOnTimeoutExecutorService

public void setOnTimeoutExecutorService(ExecutorService executorService)

Description copied from interface: ReplyManager

Sets the thread pool to use for continue routing Exchange when a timeout was triggered when doing request/reply over JMS.

Specified by:

setOnTimeoutExecutorService in interface ReplyManager

setEndpoint

public void setEndpoint(SjmsEndpoint endpoint)

Description copied from interface: ReplyManager

Sets the belonging SjmsEndpoint.

Specified by:

setEndpoint in interface ReplyManager

setReplyTo

public void setReplyTo(javax.jms.Destination replyTo)

Description copied from interface: ReplyManager

Sets the reply to queue the manager should listen for replies.

The queue is either a temporary or a persistent queue.

Specified by:

setReplyTo in interface ReplyManager

getReplyTo

public javax.jms.Destination getReplyTo()

Description copied from interface: ReplyManager

Gets the reply to queue being used

Specified by:

getReplyTo in interface ReplyManager

registerReply

public String registerReply(ReplyManager replyManager,
                            org.apache.camel.Exchange exchange,
                            org.apache.camel.AsyncCallback callback,
                            String originalCorrelationId,
                            String correlationId,
                            long requestTimeout)

Description copied from interface: ReplyManager

Register a reply

Specified by:

registerReply in interface ReplyManager

Parameters:

replyManager - the reply manager being used

exchange - the exchange

callback - the callback

originalCorrelationId - an optional original correlation id

correlationId - the correlation id to expect being used

requestTimeout - the timeout

Returns:

the correlation id used

onMessage

public void onMessage(javax.jms.Message message,
                      javax.jms.Session session)
               throws javax.jms.JMSException

Specified by:

onMessage in interface SessionMessageListener

Throws:

javax.jms.JMSException

processReply

public void processReply(ReplyHolder holder)

Description copied from interface: ReplyManager

Process the reply

Specified by:

processReply in interface ReplyManager

Parameters:

holder - containing needed data to process the reply and continue routing

handleReplyMessage

protected abstract void handleReplyMessage(String correlationID,
                                           javax.jms.Message message,
                                           javax.jms.Session session)

createListenerContainer

protected abstract MessageListenerContainer createListenerContainer()
                                                             throws Exception

Throws:

Exception

doStart

protected void doStart()
                throws Exception

Overrides:

doStart in class org.apache.camel.support.service.BaseService

Throws:

Exception

doStop

protected void doStop()
               throws Exception

Overrides:

doStop in class org.apache.camel.support.service.BaseService

Throws:

Exception