public class MessageSynchronizeQueue extends Object
Constructor and Description |
---|
MessageSynchronizeQueue(int queueSize,
String symbol) |
Modifier and Type | Method and Description |
---|---|
void |
clear()
Clear the queue.
|
int |
getCountMessageInQueue()
Returns count or messages in queue.
|
boolean |
haveIncrements()
Returns true if queue contains increment.
|
boolean |
haveOtherMessages()
Returns true if other message exists.
|
boolean |
isEmpty()
Returns true if queue contains increment.
|
boolean |
isProcessing()
Returns true if the slot is in processing state.
|
void |
lock()
Lock the slot.
|
GroupEntry |
popMessage()
Pops the message from queue.
|
FIXFieldList |
popOtherMessage()
Pop the other message from queue.
|
void |
pushMessage(GroupEntry entry)
Push message to queue.
|
void |
pushOtherMessage(FIXFieldList otherMessage)
Push other message to queue.
|
void |
startProcessing()
Start processing.
|
void |
stopProcessing()
Stop processing.
|
void |
unlock()
Un Lock the slot.
|
protected static final Log log
public MessageSynchronizeQueue(int queueSize, String symbol)
public void pushMessage(GroupEntry entry)
entry
- the entrypublic void pushOtherMessage(FIXFieldList otherMessage)
The slot can contains only a one other message.
otherMessage
- the other messagepublic boolean haveOtherMessages()
public FIXFieldList popOtherMessage()
public boolean isProcessing()
public int getCountMessageInQueue()
public void startProcessing()
public void stopProcessing()
public boolean haveIncrements()
public boolean isEmpty()
public GroupEntry popMessage()
public void lock()
public void unlock()
public void clear()
Copyright © 2000-2017 EPAM Systems. All Rights Reserved.