quickfix.mina

Class SingleThreadedEventHandlingStrategy

java.lang.Object

quickfix.mina.SingleThreadedEventHandlingStrategy

All Implemented Interfaces:

EventHandlingStrategy

public class SingleThreadedEventHandlingStrategy
extends Object
implements EventHandlingStrategy

Processes messages for all sessions in a single thread.

Field Summary

Fields

Modifier and Type	Field and Description
static String	MESSAGE_PROCESSOR_THREAD_NAME

Fields inherited from interface quickfix.mina.EventHandlingStrategy

END_OF_STREAM, THREAD_WAIT_FOR_MESSAGE_MS

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	blockInThread() Start handling of messages by message processor thread.
int	getQueueSize()
int	getQueueSize(SessionID sessionID)
SessionConnector	getSessionConnector()
void	onMessage(Session quickfixSession, Message message)
void	setExecutor(Executor executor)
void	stopHandlingMessages() Stops processing of messages without waiting for message processing thread to finish.
void	stopHandlingMessages(boolean join) Stops processing of messages and optionally waits for message processing thread to finish.

Methods inherited from class java.lang.Object

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

Field Detail

MESSAGE_PROCESSOR_THREAD_NAME

public static final String MESSAGE_PROCESSOR_THREAD_NAME

See Also:

Constant Field Values

Constructor Detail

SingleThreadedEventHandlingStrategy

public SingleThreadedEventHandlingStrategy(SessionConnector connector,
                                           int queueCapacity)

SingleThreadedEventHandlingStrategy

public SingleThreadedEventHandlingStrategy(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()

Specified by:

getSessionConnector in interface EventHandlingStrategy

Returns:

the SessionConnector associated with this strategy

blockInThread

public void blockInThread()

Start handling of messages by message processor thread. If thread is still alive, an attempt is made to stop it. An IllegalStateException is thrown if stopping the old thread was not successful. This method must not be called by several threads concurrently.

stopHandlingMessages

public void stopHandlingMessages()

Stops processing of messages without waiting for message processing thread to finish. It is advised to call stopHandlingMessages(true) instead of this method.

stopHandlingMessages

public void stopHandlingMessages(boolean join)

Stops processing of messages and optionally waits for message processing thread to finish.

Parameters:

join - true to wait for thread to finish

getQueueSize

public int getQueueSize()

Specified by:

getQueueSize in interface EventHandlingStrategy

getQueueSize

public int getQueueSize(SessionID sessionID)

Specified by:

getQueueSize in interface EventHandlingStrategy