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

java.lang.Object
  org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler
      org.apache.camel.component.jms.reply.PersistentQueueReplyHandler

All Implemented Interfaces:

ReplyHandler

public class PersistentQueueReplyHandler
extends TemporaryQueueReplyHandler

ReplyHandler to handle processing replies when using persistent queues.

Version:

Field Summary

Fields inherited from class org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler

callback, exchange, originalCorrelationId, replyManager, timeout

Constructor Summary

PersistentQueueReplyHandler(ReplyManager replyManager, org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback, String originalCorrelationId, long timeout, MessageSelectorCreator dynamicMessageSelector)

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

Constructor Detail

PersistentQueueReplyHandler

public PersistentQueueReplyHandler(ReplyManager replyManager,
                                   org.apache.camel.Exchange exchange,
                                   org.apache.camel.AsyncCallback callback,
                                   String originalCorrelationId,
                                   long timeout,
                                   MessageSelectorCreator dynamicMessageSelector)

Method Detail

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

Overrides:

onReply in class TemporaryQueueReplyHandler

Parameters:

correlationId - the correlation id

reply - 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

Overrides:

onTimeout in class TemporaryQueueReplyHandler

Parameters:

correlationId - the correlation id