quickfix.mina
Class ThreadPerSessionEventHandlingStrategy

java.lang.Object
  extended by quickfix.mina.ThreadPerSessionEventHandlingStrategy
All Implemented Interfaces:
EventHandlingStrategy

public class ThreadPerSessionEventHandlingStrategy
extends java.lang.Object
implements EventHandlingStrategy

Processes messages in a session-specific thread.


Constructor Summary
ThreadPerSessionEventHandlingStrategy()
           
 
Method Summary
 int getQueueSize()
           
 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
 void onMessage(Session quickfixSession, Message message)
           
protected  void startDispatcherThread(quickfix.mina.ThreadPerSessionEventHandlingStrategy.MessageDispatchingThread dispatcher)
           
 void stopDispatcherThreads()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ThreadPerSessionEventHandlingStrategy

public ThreadPerSessionEventHandlingStrategy()
Method Detail

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