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	Description
class	QueueableItem

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

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

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

Modifier and Type	Method	Description
void	ChroniclePersistentQueue.commit(IQueueable item)
void	ChroniclePersistentQueue.commit(IQueueable[] batchItems, int size)
void	InMemoryQueue.commit(IQueueable object)
void	InMemoryQueue.commit(IQueueable[] batchItems, int size)
void	IQueue.commit(IQueueable object)	Removes polled object from the queue.
void	IQueue.commit(IQueueable[] batchItems, int size)	Removes polled objects from the queue.
void	PersistentFileQueue.commit(IQueueable item)
void	PersistentFileQueue.commit(IQueueable[] batchItems, int size)
void	ChroniclePersistentQueue.failedProcessing(IQueueable item)
void	ChroniclePersistentQueue.failedProcessing(IQueueable[] batchItems, int size)
void	InMemoryQueue.failedProcessing(IQueueable object)
void	InMemoryQueue.failedProcessing(IQueueable[] batchItems, int size)
void	IQueue.failedProcessing(IQueueable items)	Return element to queue.
void	IQueue.failedProcessing(IQueueable[] batchItems, int size)	Return element to queue.
void	PersistentFileQueue.failedProcessing(IQueueable item)
void	PersistentFileQueue.failedProcessing(IQueueable[] batchItems, int size)
protected void	ChroniclePersistentQueue.onCommit(IQueueable x)
protected void	InMemoryQueue.onCommit(IQueueable x)
void	PersistentInMemoryQueue.onCommit(IQueueable item)
protected void	ChroniclePersistentQueue.onInsert(IQueueable x)
protected void	InMemoryQueue.onInsert(IQueueable x)
protected void	PersistentInMemoryQueue.onInsert(IQueueable item)
int	ChroniclePersistentQueue.take(IQueueable[] batch)
int	InMemoryQueue.take(IQueueable[] batch)
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	PersistentFileQueue.take(IQueueable[] batch)