Package 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

Fields

Modifier and Type	Field	Description
static final long	DEFAULT_CORRELATION_TIMEOUT

Constructor Summary

Constructors

Constructor	Description
MessageCorrelator()

Method Summary

Modifier and Type	Method	Description
Callable<quickfix.Message>	getReply(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 Details

DEFAULT_CORRELATION_TIMEOUT

public static final long DEFAULT_CORRELATION_TIMEOUT

See Also:

• Constant Field Values

Constructor Details

MessageCorrelator

public MessageCorrelator()

Method Details

getReply

public Callable<quickfix.Message> getReply(org.apache.camel.Exchange exchange)

onEvent

public void onEvent(QuickfixjEventCategory eventCategory,
 quickfix.SessionID sessionID,
 quickfix.Message message)
             throws Exception

Specified by:

onEvent in interface QuickfixjEventListener

Throws:

Exception