| 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.