Package | Description |
---|---|
reactor.io.queue.spec |
Specs provide a simple fluent DSL for creating
PersistentQueues by
specifying common options. |
Modifier and Type | Method and Description |
---|---|
PersistentQueueSpec<T> |
PersistentQueueSpec.basePath(String basePath) |
PersistentQueueSpec<T> |
PersistentQueueSpec.clearOnStart(boolean clearOnStart) |
PersistentQueueSpec<T> |
PersistentQueueSpec.codec(Codec<Buffer,T,T> codec) |
PersistentQueueSpec<T> |
PersistentQueueSpec.dataBlockSize(int size) |
PersistentQueueSpec<T> |
PersistentQueueSpec.deleteOnExit(boolean deleteOnExit) |
PersistentQueueSpec<T> |
PersistentQueueSpec.indexBlockSize(int indexBlockSize) |
PersistentQueueSpec<T> |
PersistentQueueSpec.sync(boolean synchronousMode) |
Copyright © 2016. All rights reserved.