org.apache.camel.component.jms.reply
Class TemporaryQueueReplyHandler
java.lang.Object
org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler
- All Implemented Interfaces:
- ReplyHandler
- Direct Known Subclasses:
- QueueReplyHandler
public class TemporaryQueueReplyHandler
- extends Object
- implements ReplyHandler
ReplyHandler
to handle processing replies when using temporary queues.
- Version:
Method Summary |
void |
onReply(String correlationId,
javax.jms.Message reply)
The reply message was received |
void |
onTimeout(String correlationId)
The reply message was not received and a timeout triggered |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
replyManager
protected final ReplyManager replyManager
exchange
protected final org.apache.camel.Exchange exchange
callback
protected final org.apache.camel.AsyncCallback callback
originalCorrelationId
protected final String originalCorrelationId
correlationId
protected final String correlationId
timeout
protected final long timeout
TemporaryQueueReplyHandler
public TemporaryQueueReplyHandler(ReplyManager replyManager,
org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback,
String originalCorrelationId,
String correlationId,
long timeout)
onReply
public void onReply(String correlationId,
javax.jms.Message reply)
- Description copied from interface:
ReplyHandler
- The reply message was received
- Specified by:
onReply
in interface ReplyHandler
- Parameters:
correlationId
- the correlation idreply
- the reply message
onTimeout
public void onTimeout(String correlationId)
- Description copied from interface:
ReplyHandler
- The reply message was not received and a timeout triggered
- Specified by:
onTimeout
in interface ReplyHandler
- Parameters:
correlationId
- the correlation id
Apache Camel