org.apache.camel.component.quickfixj
Class MessageCorrelator

java.lang.Object
  org.apache.camel.component.quickfixj.MessageCorrelator

All Implemented Interfaces:

QuickfixjEventListener

public class MessageCorrelator
extends Object
implements QuickfixjEventListener

Field Summary

static long

DEFAULT_CORRELATION_TIMEOUT

Constructor Summary

MessageCorrelator()

Method Summary

Callable<quickfix.Message>	getReply(quickfix.SessionID sessionID, org.apache.camel.Exchange exchange)
void	onEvent(QuickfixjEventCategory eventCategory, quickfix.SessionID sessionID, quickfix.Message message)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_CORRELATION_TIMEOUT

public static final long DEFAULT_CORRELATION_TIMEOUT

See Also:

Constant Field Values

Constructor Detail

MessageCorrelator

public MessageCorrelator()

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 interface QuickfixjEventListener

Throws:

Exception