Package reactor.queue

Queue implementations that provide a persistence strategy for making sure items in the Queue aren't lost.

See: Description

Interface Summary

Interface	Description
QueuePersistor<T>	Implementations of this interface are responsible for persisting the elements of a PersistentQueue.

Class Summary

Class	Description
BlockingQueueFactory	A factory for creating BlockingQueue instances.
IndexedChronicleQueuePersistor<T>	A QueuePersistor implementation that uses a Java Chronicle IndexedChronicle to persist items in the queue.
InMemoryQueuePersistor<T>	A QueuePersistor implementations that stores items in-memory.
PersistentQueue<T>	A PersistentQueue is a Queue implementation that delegates the actual storage of the elements in the queue to a QueuePersistor.

Package reactor.queue Description

Queue implementations that provide a persistence strategy for making sure items in the Queue aren't lost.