Uses of Interface
com.epam.fixengine.jms.storage.queue.IQueueable
Packages that use IQueueable
-
Uses of IQueueable in com.epam.fixengine.jms.storage.queue
Classes in com.epam.fixengine.jms.storage.queue that implement IQueueableMethods in com.epam.fixengine.jms.storage.queue that return IQueueableModifier and TypeMethodDescriptionChroniclePersistentQueue.poll()
InMemoryQueue.poll()
IQueue.poll()
Poll object from the queue (doesn't remove it from queue yet!).PersistentFileQueue.poll()
ChroniclePersistentQueue.take()
InMemoryQueue.take()
Retrieves and mark as processing the head of this queue, waiting if necessary until an element becomes available.IQueue.take()
Retrieves and mark as processing the head of this queue, waiting if necessary until an element becomes available.PersistentFileQueue.take()
Methods in com.epam.fixengine.jms.storage.queue with parameters of type IQueueableModifier and TypeMethodDescriptionvoid
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)