Package | Description |
---|---|
reactor.io.queue |
Queue implementations that provide a persistence strategy for making sure items in the Queue aren't lost. |
Modifier and Type | Class and Description |
---|---|
class |
ChronicleQueuePersistor<T>
A
QueuePersistor implementation that uses a Java
Chronicle IndexedChronicle to persist items in the queue. |
class |
InMemoryQueuePersistor<T>
A
QueuePersistor implementations that stores items in-memory. |
Constructor and Description |
---|
PersistentQueue(QueuePersistor<T> persistor)
Create a PersistentQueue using the given
QueuePersistor . |
Copyright © 2016. All rights reserved.