com.epam.bovespafast.impl.message

Class MessageSynchronizeQueue

java.lang.Object

com.epam.bovespafast.impl.message.MessageSynchronizeQueue

public class MessageSynchronizeQueue
extends Object

Message slot object contains three types of messages: one snapshot(the last snapshot for this instrument), the all increments and other messages(this message can be statistic or can be news or something else).

Field Summary

Fields

Modifier and Type	Field and Description
protected static com.epam.common.logging.Log	log

Constructor Summary

Constructors

Constructor and Description
MessageSynchronizeQueue(int queueSize, String symbol)

Method Summary

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.
com.epam.fix.message.FIXFieldList	popOtherMessage() Pop the other message from queue.
void	pushMessage(GroupEntry entry) Push message to queue.
void	pushOtherMessage(com.epam.fix.message.FIXFieldList otherMessage) Push other message to queue.
void	startProcessing() Start processing.
void	stopProcessing() Stop processing.
void	unlock() Un Lock the slot.

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final com.epam.common.logging.Log log

Constructor Detail

MessageSynchronizeQueue

public MessageSynchronizeQueue(int queueSize,
                               String symbol)

Method Detail

pushMessage

public void pushMessage(GroupEntry entry)

Push message to queue.

Parameters:

entry - the entry

pushOtherMessage

public void pushOtherMessage(com.epam.fix.message.FIXFieldList otherMessage)

Push other message to queue.

The slot can contains only a one other message.

Parameters:

otherMessage - the other message

haveOtherMessages

public boolean haveOtherMessages()

Returns true if other message exists.

popOtherMessage

public com.epam.fix.message.FIXFieldList popOtherMessage()

Pop the other message from queue.

isProcessing

public boolean isProcessing()

Returns true if the slot is in processing state.

getCountMessageInQueue

public int getCountMessageInQueue()

Returns count or messages in queue.

startProcessing

public void startProcessing()

Start processing.

stopProcessing

public void stopProcessing()

Stop processing.

haveIncrements

public boolean haveIncrements()

Returns true if queue contains increment.

isEmpty

public boolean isEmpty()

Returns true if queue contains increment.

popMessage

public GroupEntry popMessage()

Pops the message from queue.

lock

public void lock()

Lock the slot.

unlock

public void unlock()

Un Lock the slot.

clear

public void clear()

Clear the queue.