protected ReplyHandler |
QueueReplyManager.createReplyHandler(ReplyManager replyManager,
org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback,
String originalCorrelationId,
String correlationId,
long requestTimeout) |
protected abstract ReplyHandler |
ReplyManagerSupport.createReplyHandler(ReplyManager replyManager,
org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback,
String originalCorrelationId,
String correlationId,
long requestTimeout) |
protected ReplyHandler |
TemporaryQueueReplyManager.createReplyHandler(ReplyManager replyManager,
org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback,
String originalCorrelationId,
String correlationId,
long requestTimeout) |
ReplyHandler |
CorrelationTimeoutMap.get(String key) |
ReplyHandler |
CorrelationTimeoutMap.put(String key,
ReplyHandler value,
long timeoutMillis) |
ReplyHandler |
CorrelationTimeoutMap.putIfAbsent(String key,
ReplyHandler value,
long timeoutMillis) |
ReplyHandler |
CorrelationTimeoutMap.remove(String key) |
protected ReplyHandler |
ReplyManagerSupport.waitForProvisionCorrelationToBeUpdated(String correlationID,
javax.jms.Message message)
IMPORTANT: This logic is only being used due to high performance in-memory only
testing using InOut over JMS.
|