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 voidadd(T msg)Adds element to the tail of the queue.voiddispose()booleanisEmpty()booleanisFull()Tpeek()Retrieves, but does not remove, the head of this queue, or returnsnullif this queue is empty.TpeekLast()Retrieves, but does not remove, the tail of this queue, or returnsnullif this queue is empty.voidrelease(T msg)Tremove()Retrieves and removes the head of this queue, or returnsnullif this queue is empty.intsize()
-
-
-
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 returnsnullif this queue is empty.- Returns:
- the head of this queue, or
nullif this queue is empty
-
peek
T peek()
Retrieves, but does not remove, the head of this queue, or returnsnullif this queue is empty.
-
peekLast
T peekLast()
Retrieves, but does not remove, the tail of this queue, or returnsnullif this queue is empty.
-
isEmpty
boolean isEmpty()
-
isFull
boolean isFull()
-
size
int size()
-
release
void release(T msg)
-
dispose
void dispose()
-
-