org.apache.camel.component.sjms.consumer
Class InOutMessageHandler
java.lang.Object
org.apache.camel.component.sjms.consumer.AbstractMessageHandler
org.apache.camel.component.sjms.consumer.InOutMessageHandler
- All Implemented Interfaces:
- javax.jms.MessageListener
public class InOutMessageHandler
- extends AbstractMessageHandler
TODO Add Class documentation for AbstractMessageHandler
TODO Create a producer
cache manager to store and purge unused cashed producers or we will have a
memory leak
Method Summary |
void |
close()
Method will be called to |
void |
handleMessage(org.apache.camel.Exchange exchange)
|
Methods inherited from class org.apache.camel.component.sjms.consumer.AbstractMessageHandler |
getCommitStrategy, getEndpoint, getProcessor, getSession, isSynchronous, isTopic, isTransacted, onMessage, setProcessor, setSession, setSynchronous, setTopic, setTransacted |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
InOutMessageHandler
public InOutMessageHandler(org.apache.camel.Endpoint endpoint,
ExecutorService executor)
- Parameters:
endpoint
- executor
-
InOutMessageHandler
public InOutMessageHandler(org.apache.camel.Endpoint endpoint,
ExecutorService executor,
org.apache.camel.spi.Synchronization synchronization)
- Parameters:
endpoint
- executor
- synchronization
-
handleMessage
public void handleMessage(org.apache.camel.Exchange exchange)
- Specified by:
handleMessage
in class AbstractMessageHandler
- Parameters:
message
-
close
public void close()
- Description copied from class:
AbstractMessageHandler
- Method will be called to
- Specified by:
close
in class AbstractMessageHandler
Apache Camel