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 |
setExecutor(Executor executor) |
void |
stopHandlingMessages() |
void |
stopHandlingMessages(boolean join) |
public static final String MESSAGE_PROCESSOR_THREAD_NAME
public SingleThreadedEventHandlingStrategy(SessionConnector connector, int queueCapacity)
public void setExecutor(Executor executor)
public void onMessage(Session quickfixSession, Message message)
onMessage in interface EventHandlingStrategypublic SessionConnector getSessionConnector()
getSessionConnector in interface EventHandlingStrategypublic void block()
public void blockInThread()
public void stopHandlingMessages()
public void stopHandlingMessages(boolean join)
public int getQueueSize()
getQueueSize in interface EventHandlingStrategypublic int getQueueSize(SessionID sessionID)
getQueueSize in interface EventHandlingStrategyCopyright © 2017. All rights reserved.