|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface ReplyManager
The ReplyManager
is responsible for handling request-reply
over JMS.
Method Summary | |
---|---|
javax.jms.Destination |
getReplyTo()
Gets the reply to queue being used |
void |
processReply(ReplyHolder holder)
Process the reply |
String |
registerReply(ReplyManager replyManager,
org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback,
String originalCorrelationId,
String correlationId,
long requestTimeout)
Register a reply |
void |
setEndpoint(JmsEndpoint endpoint)
Sets the belonging JmsEndpoint . |
void |
setReplyTo(javax.jms.Destination replyTo)
Sets the reply to queue the manager should listen for replies. |
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 |
setScheduledExecutorService(ScheduledExecutorService executorService)
Sets the scheduled to use when checking for timeouts (no reply received within a given time period) |
void |
updateCorrelationId(String correlationId,
String newCorrelationId,
long requestTimeout)
Updates the correlation id to the new correlation id. |
Methods inherited from interface javax.jms.MessageListener |
---|
onMessage |
Method Detail |
---|
void setEndpoint(JmsEndpoint endpoint)
JmsEndpoint
.
void setReplyTo(javax.jms.Destination replyTo)
void setScheduledExecutorService(ScheduledExecutorService executorService)
javax.jms.Destination getReplyTo()
void setReplyToSelectorHeader(org.apache.camel.Message camelMessage, javax.jms.Message jmsMessage) throws javax.jms.JMSException
javax.jms.JMSException
String registerReply(ReplyManager replyManager, org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback, String originalCorrelationId, String correlationId, long requestTimeout)
replyManager
- the reply manager being usedexchange
- the exchangecallback
- the callbackoriginalCorrelationId
- an optional original correlation idcorrelationId
- the correlation id to expect being usedrequestTimeout
- the timeout
void updateCorrelationId(String correlationId, String newCorrelationId, long requestTimeout)
correlationId
- the provisional correlation idnewCorrelationId
- the real correlation idrequestTimeout
- the timeoutvoid processReply(ReplyHolder holder)
holder
- containing needed data to process the reply and continue routing
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |