Class MessageCorrelator
- java.lang.Object
-
- org.apache.camel.component.quickfixj.MessageCorrelator
-
- All Implemented Interfaces:
QuickfixjEventListener
public class MessageCorrelator extends Object implements QuickfixjEventListener
-
-
Field Summary
Fields Modifier and Type Field Description static long
DEFAULT_CORRELATION_TIMEOUT
-
Constructor Summary
Constructors Constructor Description MessageCorrelator()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Callable<quickfix.Message>
getReply(quickfix.SessionID sessionID, org.apache.camel.Exchange exchange)
void
onEvent(QuickfixjEventCategory eventCategory, quickfix.SessionID sessionID, quickfix.Message message)
-
-
-
Field Detail
-
DEFAULT_CORRELATION_TIMEOUT
public static final long DEFAULT_CORRELATION_TIMEOUT
- See Also:
- Constant Field Values
-
-
Method Detail
-
getReply
public Callable<quickfix.Message> getReply(quickfix.SessionID sessionID, org.apache.camel.Exchange exchange) throws InterruptedException, org.apache.camel.ExchangeTimedOutException
- Throws:
InterruptedException
org.apache.camel.ExchangeTimedOutException
-
onEvent
public void onEvent(QuickfixjEventCategory eventCategory, quickfix.SessionID sessionID, quickfix.Message message) throws Exception
- Specified by:
onEvent
in interfaceQuickfixjEventListener
- Throws:
Exception
-
-