org.gytheio.messaging.camel

Class CamelRequestReplyMessageProducer.ReplyCallable

java.lang.Object

org.gytheio.messaging.camel.CamelRequestReplyMessageProducer.ReplyCallable

All Implemented Interfaces:

Callable<RP>

Enclosing class:

CamelRequestReplyMessageProducer<RQ extends org.gytheio.messaging.Request<RP>,RP extends org.gytheio.messaging.Reply>

public class CamelRequestReplyMessageProducer.ReplyCallable
extends Object
implements Callable<RP>

Class which polls the pending requests map to determine if a correlated reply has been received.

Constructor Summary

Constructors

Constructor and Description
CamelRequestReplyMessageProducer.ReplyCallable(String requestId) Constructor which takes a correlating request ID

Method Summary

Methods

Modifier and Type	Method and Description
RP	call()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CamelRequestReplyMessageProducer.ReplyCallable

public CamelRequestReplyMessageProducer.ReplyCallable(String requestId)

Constructor which takes a correlating request ID

Parameters:

requestId -

Method Detail

call

public RP call()
                                            throws Exception

Specified by:

call in interface Callable<RP extends org.gytheio.messaging.Reply>

Throws:

Exception