quickfix.mina

Class ThreadPerSessionEventHandlingStrategy

java.lang.Object

quickfix.mina.ThreadPerSessionEventHandlingStrategy

All Implemented Interfaces:

EventHandlingStrategy

public class ThreadPerSessionEventHandlingStrategy
extends Object
implements EventHandlingStrategy

Processes messages in a session-specific thread.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	ThreadPerSessionEventHandlingStrategy.MessageDispatchingThread
protected static class	ThreadPerSessionEventHandlingStrategy.ThreadAdapter A stand-in for the Thread class that delegates to an Executor.

Field Summary

Fields inherited from interface quickfix.mina.EventHandlingStrategy

END_OF_STREAM, THREAD_WAIT_FOR_MESSAGE_MS

Constructor Summary

Constructors

Constructor and Description
ThreadPerSessionEventHandlingStrategy(SessionConnector connector, int queueCapacity)
ThreadPerSessionEventHandlingStrategy(SessionConnector connector, int queueLowerWatermark, int queueUpperWatermark)

Method Summary

Modifier and Type	Method and Description
protected ThreadPerSessionEventHandlingStrategy.MessageDispatchingThread	getDispatcher(SessionID sessionID)
protected Message	getNextMessage(quickfix.mina.QueueTracker<Message> queueTracker) Get the next message from the messages BlockingQueue.
int	getQueueSize()
int	getQueueSize(SessionID sessionID)
SessionConnector	getSessionConnector() The SessionConnector is not directly required for thread-per-session handler - we don't multiplex between multiple sessions here.
void	onMessage(Session quickfixSession, Message message)
void	setExecutor(Executor executor)
protected void	startDispatcherThread(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(SessionConnector connector,
                                             int queueCapacity)

ThreadPerSessionEventHandlingStrategy

public ThreadPerSessionEventHandlingStrategy(SessionConnector connector,
                                             int queueLowerWatermark,
                                             int queueUpperWatermark)

Method Detail

setExecutor

public void setExecutor(Executor executor)

onMessage

public void onMessage(Session quickfixSession,
                      Message message)

Specified by:

onMessage in interface EventHandlingStrategy

getSessionConnector

public SessionConnector getSessionConnector()

The SessionConnector is not directly required for thread-per-session handler - we don't multiplex between multiple sessions here. However it is made available here for other callers (such as SessionProviders wishing to register dynamic sessions).

Specified by:

getSessionConnector in interface EventHandlingStrategy

Returns:

the SessionConnector

startDispatcherThread

protected void startDispatcherThread(ThreadPerSessionEventHandlingStrategy.MessageDispatchingThread dispatcher)

stopDispatcherThreads

public void stopDispatcherThreads()

getDispatcher

protected ThreadPerSessionEventHandlingStrategy.MessageDispatchingThread getDispatcher(SessionID sessionID)

getNextMessage

protected Message getNextMessage(quickfix.mina.QueueTracker<Message> queueTracker)
                          throws InterruptedException

Get the next message from the messages BlockingQueue.

We do not block indefinitely as that would prevent this thread from ever stopping

Parameters:

queueTracker -

Returns:

next message or null if nothing arrived within the timeout period

Throws:

InterruptedException

See Also:

EventHandlingStrategy.THREAD_WAIT_FOR_MESSAGE_MS

getQueueSize

public int getQueueSize()

Specified by:

getQueueSize in interface EventHandlingStrategy

getQueueSize

public int getQueueSize(SessionID sessionID)

Specified by:

getQueueSize in interface EventHandlingStrategy