Package deltix.qsrv.hf.blocks

Class RawMessageQueue

java.lang.Object

deltix.qsrv.hf.blocks.RawMessageQueue

All Implemented Interfaces:

MarketMessageQueue<RawMessage>

public class RawMessageQueue
extends java.lang.Object
implements MarketMessageQueue<RawMessage>

Constructor Summary

Constructors

Constructor	Description
RawMessageQueue(int size)

Method Summary

Modifier and Type	Method	Description
void	add(RawMessage msg)	Adds element to the tail of the queue.
void	dispose()
boolean	isEmpty()
boolean	isFull()
RawMessage	peek()	Retrieves, but does not remove, the head of this queue, or returns null if this queue is empty.
RawMessage	peekLast()	Retrieves, but does not remove, the tail of this queue, or returns null if this queue is empty.
void	release(RawMessage msg)
RawMessage	remove()	Retrieves and removes the head of this queue, or returns null if this queue is empty.
int	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

RawMessageQueue

public RawMessageQueue(int size)

Parameters:

size - queue size

Method Detail

add

public void add(RawMessage msg)

Description copied from interface: MarketMessageQueue

Adds element to the tail of the queue. If capacity is exceeded new element overrides the oldest one (head)

Specified by:

add in interface MarketMessageQueue<RawMessage>

remove

public RawMessage remove()

Description copied from interface: MarketMessageQueue

Retrieves and removes the head of this queue, or returns null if this queue is empty.

Specified by:

remove in interface MarketMessageQueue<RawMessage>

Returns:

the head of this queue, or null if this queue is empty

peek

public RawMessage peek()

Description copied from interface: MarketMessageQueue

Retrieves, but does not remove, the head of this queue, or returns null if this queue is empty.

Specified by:

peek in interface MarketMessageQueue<RawMessage>

peekLast

public RawMessage peekLast()

Description copied from interface: MarketMessageQueue

Retrieves, but does not remove, the tail of this queue, or returns null if this queue is empty.

Specified by:

peekLast in interface MarketMessageQueue<RawMessage>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface MarketMessageQueue<RawMessage>

isFull

public boolean isFull()

Specified by:

isFull in interface MarketMessageQueue<RawMessage>

size

public int size()

Specified by:

size in interface MarketMessageQueue<RawMessage>

dispose

public void dispose()

Specified by:

dispose in interface MarketMessageQueue<RawMessage>

release

public void release(RawMessage msg)

Specified by:

release in interface MarketMessageQueue<RawMessage>