Uses of Interface
com.epam.fixengine.jms.storage.queue.IQueueable

Packages that use IQueueable

Package	Description
com.epam.fixengine.jms.storage.queue

Uses of IQueueable in com.epam.fixengine.jms.storage.queue

Classes in com.epam.fixengine.jms.storage.queue that implement IQueueable

Modifier and Type	Class and Description
class	QueueableItem

Methods in com.epam.fixengine.jms.storage.queue that return IQueueable

Modifier and Type	Method and Description
IQueueable	IQueue.poll() Poll object from the queue (doesn't remove it from queue yet!).
IQueueable	InMemoryQueue.poll()
IQueueable	IQueue.take() Retrieves and mark as processing the head of this queue, waiting if necessary until an element becomes available.
IQueueable	InMemoryQueue.take() Retrieves and mark as processing the head of this queue, waiting if necessary until an element becomes available.

Methods in com.epam.fixengine.jms.storage.queue with parameters of type IQueueable

Modifier and Type	Method and Description
void	IQueue.commit(IQueueable object) Removes polled object from the queue.
void	InMemoryQueue.commit(IQueueable object)
void	IQueue.commit(IQueueable[] batchItems, int size) Removes polled objects from the queue.
void	InMemoryQueue.commit(IQueueable[] batchItems, int size)
void	IQueue.failedProcessing(IQueueable items) Return element to queue.
void	InMemoryQueue.failedProcessing(IQueueable object)
void	IQueue.failedProcessing(IQueueable[] batchItems, int size) Return element to queue.
void	InMemoryQueue.failedProcessing(IQueueable[] batchItems, int size)
void	PersistentInMemoryQueue.onCommit(IQueueable item)
protected void	InMemoryQueue.onCommit(IQueueable x)
protected void	PersistentInMemoryQueue.onInsert(IQueueable item)
protected void	InMemoryQueue.onInsert(IQueueable x)
int	IQueue.take(IQueueable[] batch) Retrieves and mark as processing the batch elements from head of this queue, waiting if necessary until at least one element becomes available.
int	InMemoryQueue.take(IQueueable[] batch)