org.apache.camel.component.jms.reply
Class TemporaryQueueReplyManager

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.component.jms.reply.ReplyManagerSupport
          extended by org.apache.camel.component.jms.reply.TemporaryQueueReplyManager
All Implemented Interfaces:
javax.jms.MessageListener, ReplyManager, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class TemporaryQueueReplyManager
extends ReplyManagerSupport

A ReplyManager when using temporary queues.

Version:

Field Summary
 
Fields inherited from class org.apache.camel.component.jms.reply.ReplyManagerSupport
camelContext, correlation, endpoint, executorService, listenerContainer, log, replyTo, replyToLatch, replyToTimeout
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
TemporaryQueueReplyManager(org.apache.camel.CamelContext camelContext)
           
 
Method Summary
protected  org.springframework.jms.listener.AbstractMessageListenerContainer createListenerContainer()
           
 javax.jms.Destination getReplyTo()
          Gets the reply to queue being used
protected  void handleReplyMessage(String correlationID, javax.jms.Message message)
           
 String registerReply(ReplyManager replyManager, org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback, String originalCorrelationId, String correlationId, long requestTimeout)
          Register a reply
 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.
 
Methods inherited from class org.apache.camel.component.jms.reply.ReplyManagerSupport
doStart, doStop, onMessage, processReply, setEndpoint, setReplyTo, setScheduledExecutorService, waitForProvisionCorrelationToBeUpdated
 
Methods inherited from class org.apache.camel.support.ServiceSupport
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TemporaryQueueReplyManager

public TemporaryQueueReplyManager(org.apache.camel.CamelContext camelContext)
Method Detail

getReplyTo

public javax.jms.Destination getReplyTo()
Description copied from interface: ReplyManager
Gets the reply to queue being used

Specified by:
getReplyTo in interface ReplyManager
Overrides:
getReplyTo in class ReplyManagerSupport

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

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

updateCorrelationId

public void updateCorrelationId(String correlationId,
                                String newCorrelationId,
                                long requestTimeout)
Description copied from interface: ReplyManager
Updates the correlation id to the new correlation id.

This is only used when useMessageIDasCorrelationID option is used, which means a provisional correlation id is first used, then after the message has been sent, the real correlation id is known. This allows us then to update the internal mapping to expect the real correlation id.

Parameters:
correlationId - the provisional correlation id
newCorrelationId - the real correlation id
requestTimeout - the timeout

handleReplyMessage

protected void handleReplyMessage(String correlationID,
                                  javax.jms.Message message)
Specified by:
handleReplyMessage in class ReplyManagerSupport

setReplyToSelectorHeader

public void setReplyToSelectorHeader(org.apache.camel.Message camelMessage,
                                     javax.jms.Message jmsMessage)
                              throws javax.jms.JMSException
Description copied from interface: ReplyManager
To be used when a reply queue is used with a custom JMS selector is being used.

Throws:
javax.jms.JMSException

createListenerContainer

protected org.springframework.jms.listener.AbstractMessageListenerContainer createListenerContainer()
                                                                                             throws Exception
Specified by:
createListenerContainer in class ReplyManagerSupport
Throws:
Exception


Apache Camel