public class MessageCorrelator extends Object implements QuickfixjEventListener
Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_CORRELATION_TIMEOUT |
Constructor and Description |
---|
MessageCorrelator() |
Modifier and Type | Method and Description |
---|---|
Callable<quickfix.Message> |
getReply(quickfix.SessionID sessionID,
org.apache.camel.Exchange exchange) |
void |
onEvent(QuickfixjEventCategory eventCategory,
quickfix.SessionID sessionID,
quickfix.Message message) |
public static final long DEFAULT_CORRELATION_TIMEOUT
public Callable<quickfix.Message> getReply(quickfix.SessionID sessionID, org.apache.camel.Exchange exchange) throws InterruptedException, org.apache.camel.ExchangeTimedOutException
InterruptedException
org.apache.camel.ExchangeTimedOutException
public void onEvent(QuickfixjEventCategory eventCategory, quickfix.SessionID sessionID, quickfix.Message message) throws Exception
onEvent
in interface QuickfixjEventListener
Exception
Apache Camel