org.apache.camel.component.jms.requestor
Class PersistentReplyToRequestor

java.lang.Object
  extended by org.apache.camel.impl.ServiceSupport
      extended by org.apache.camel.component.jms.requestor.Requestor
          extended by org.apache.camel.component.jms.requestor.PersistentReplyToRequestor
All Implemented Interfaces:
MessageListener, Service

public class PersistentReplyToRequestor
extends Requestor


Nested Class Summary
static class PersistentReplyToRequestor.CamelDefaultMessageListenerContainer
           
static class PersistentReplyToRequestor.CamelDefaultMessageListenerContainer102
           
 class PersistentReplyToRequestor.DestinationResolverDelegate
           
static interface PersistentReplyToRequestor.MessageSelectorComposer
           
 
Constructor Summary
PersistentReplyToRequestor(JmsConfiguration configuration, ScheduledExecutorService executorService)
           
 
Method Summary
protected  FutureHandler createFutureHandler(DeferredRequestReplyMap.DeferredMessageSentCallback callback)
           
protected  FutureHandler createFutureHandler(String correlationID)
           
 AbstractMessageListenerContainer createListenerContainer()
           
 void setReplyToSelectorHeader(Message in, Message jmsIn)
           
 
Methods inherited from class org.apache.camel.component.jms.requestor.Requestor
doStart, doStop, getConfiguration, getDeferredReplyMap, getDeferredRequestMap, getDeferredRequestReplyMap, getListenerContainer, getMaxRequestTimeout, getOutterInstance, getReceiveFuture, getReceiveFuture, getReplyTo, getRequestMap, getUuidGenerator, onMessage, removeDeferredRequestReplyMap, setListenerContainer, setReplyTo
 
Methods inherited from class org.apache.camel.impl.ServiceSupport
addChildService, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, removeChildService, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

PersistentReplyToRequestor

public PersistentReplyToRequestor(JmsConfiguration configuration,
                                  ScheduledExecutorService executorService)
Method Detail

createFutureHandler

protected FutureHandler createFutureHandler(String correlationID)
Overrides:
createFutureHandler in class Requestor

createFutureHandler

protected FutureHandler createFutureHandler(DeferredRequestReplyMap.DeferredMessageSentCallback callback)
Overrides:
createFutureHandler in class Requestor

createListenerContainer

public AbstractMessageListenerContainer createListenerContainer()
Overrides:
createListenerContainer in class Requestor

setReplyToSelectorHeader

public void setReplyToSelectorHeader(Message in,
                                     Message jmsIn)
                              throws JMSException
Overrides:
setReplyToSelectorHeader in class Requestor
Throws:
JMSException


Copyright © 2007-2010 IONA Open Source Community. All Rights Reserved.