Package deltix.qsrv.hf.blocks
Interface MarketMessageQueue<T>
-
- All Known Implementing Classes:
PooledMarketMessageQueue
,RawMessageQueue
,SimpleMarketMessageQueue
public interface MarketMessageQueue<T>
- See Also:
for synchronized wrapper
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
add(T msg)
Adds element to the tail of the queue.void
dispose()
boolean
isEmpty()
boolean
isFull()
T
peek()
Retrieves, but does not remove, the head of this queue, or returnsnull
if this queue is empty.T
peekLast()
Retrieves, but does not remove, the tail of this queue, or returnsnull
if this queue is empty.void
release(T msg)
T
remove()
Retrieves and removes the head of this queue, or returnsnull
if this queue is empty.int
size()
-
-
-
Method Detail
-
add
void add(T msg)
Adds element to the tail of the queue. If capacity is exceeded new element overrides the oldest one (head)
-
remove
T remove()
Retrieves and removes the head of this queue, or returnsnull
if this queue is empty.- Returns:
- the head of this queue, or
null
if this queue is empty
-
peek
T peek()
Retrieves, but does not remove, the head of this queue, or returnsnull
if this queue is empty.
-
peekLast
T peekLast()
Retrieves, but does not remove, the tail of this queue, or returnsnull
if this queue is empty.
-
isEmpty
boolean isEmpty()
-
isFull
boolean isFull()
-
size
int size()
-
release
void release(T msg)
-
dispose
void dispose()
-
-