public class SingleThreadedEventHandlingStrategy extends Object implements EventHandlingStrategy
Modifier and Type | Field and Description |
---|---|
static String |
MESSAGE_PROCESSOR_THREAD_NAME |
END_OF_STREAM, THREAD_WAIT_FOR_MESSAGE_MS
Constructor and Description |
---|
SingleThreadedEventHandlingStrategy(SessionConnector connector,
int queueCapacity) |
Modifier and Type | Method and Description |
---|---|
void |
block() |
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 |
stopHandlingMessages() |
void |
stopHandlingMessages(boolean join) |
public static final String MESSAGE_PROCESSOR_THREAD_NAME
public SingleThreadedEventHandlingStrategy(SessionConnector connector, int queueCapacity)
public void onMessage(Session quickfixSession, Message message)
onMessage
in interface EventHandlingStrategy
public SessionConnector getSessionConnector()
getSessionConnector
in interface EventHandlingStrategy
public void block()
public void blockInThread()
public void stopHandlingMessages()
public void stopHandlingMessages(boolean join)
public int getQueueSize()
getQueueSize
in interface EventHandlingStrategy
public int getQueueSize(SessionID sessionID)
getQueueSize
in interface EventHandlingStrategy
Copyright © 2016. All rights reserved.