public class TemporaryQueueReplyManager extends ReplyManagerSupport
ReplyManager
when using temporary queues.camelContext, correlation, correlationProperty, endpoint, executorService, listenerContainer, log, replyTo, replyToLatch, replyToTimeout, scheduledExecutorService
Constructor and Description |
---|
TemporaryQueueReplyManager(org.apache.camel.CamelContext camelContext) |
Modifier and Type | Method and Description |
---|---|
protected org.springframework.jms.listener.AbstractMessageListenerContainer |
createListenerContainer() |
protected ReplyHandler |
createReplyHandler(ReplyManager replyManager,
org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback,
String originalCorrelationId,
String correlationId,
long requestTimeout) |
javax.jms.Destination |
getReplyTo()
Gets the reply to queue being used
|
protected void |
handleReplyMessage(String correlationID,
javax.jms.Message message,
javax.jms.Session session) |
void |
setReplyToSelectorHeader(org.apache.camel.Message camelMessage,
javax.jms.Message jmsMessage)
To be used when a reply queue is used with a custom JMS selector is being used.
|
void |
updateCorrelationId(String correlationId,
String newCorrelationId,
long requestTimeout)
Updates the correlation id to the new correlation id.
|
doStart, doStop, onMessage, processReply, registerReply, setCorrelationProperty, setEndpoint, setOnTimeoutExecutorService, setReplyTo, setScheduledExecutorService, waitForProvisionCorrelationToBeUpdated
public TemporaryQueueReplyManager(org.apache.camel.CamelContext camelContext)
public javax.jms.Destination getReplyTo()
ReplyManager
getReplyTo
in interface ReplyManager
getReplyTo
in class ReplyManagerSupport
protected ReplyHandler createReplyHandler(ReplyManager replyManager, org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback, String originalCorrelationId, String correlationId, long requestTimeout)
createReplyHandler
in class ReplyManagerSupport
public void updateCorrelationId(String correlationId, String newCorrelationId, long requestTimeout)
ReplyManager
correlationId
- the provisional correlation idnewCorrelationId
- the real correlation idrequestTimeout
- the timeoutprotected void handleReplyMessage(String correlationID, javax.jms.Message message, javax.jms.Session session)
handleReplyMessage
in class ReplyManagerSupport
public void setReplyToSelectorHeader(org.apache.camel.Message camelMessage, javax.jms.Message jmsMessage) throws javax.jms.JMSException
ReplyManager
javax.jms.JMSException
protected org.springframework.jms.listener.AbstractMessageListenerContainer createListenerContainer() throws Exception
createListenerContainer
in class ReplyManagerSupport
Exception
Apache Camel