quickfix.mina
Class ThreadPerSessionEventHandlingStrategy
java.lang.Object
quickfix.mina.ThreadPerSessionEventHandlingStrategy
- All Implemented Interfaces:
- EventHandlingStrategy
public class ThreadPerSessionEventHandlingStrategy
- extends java.lang.Object
- implements EventHandlingStrategy
Processes messages in a session-specific thread.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ThreadPerSessionEventHandlingStrategy
public ThreadPerSessionEventHandlingStrategy()
onMessage
public void onMessage(Session quickfixSession,
Message message)
- Specified by:
onMessage
in interface EventHandlingStrategy
getSessionConnector
public SessionConnector getSessionConnector()
- There is no such thing as a SesionConnector for thread-per-session handler - we don't multiplex
between multiple sessions here so this is null
- Specified by:
getSessionConnector
in interface EventHandlingStrategy
startDispatcherThread
protected void startDispatcherThread(quickfix.mina.ThreadPerSessionEventHandlingStrategy.MessageDispatchingThread dispatcher)
stopDispatcherThreads
public void stopDispatcherThreads()
getQueueSize
public int getQueueSize()
- Specified by:
getQueueSize
in interface EventHandlingStrategy