public class PersistentQueueSpec<T> extends Object implements Supplier<PersistentQueue<T>>
PersistentQueue
instance.Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_BASE_PATH |
Constructor and Description |
---|
PersistentQueueSpec() |
Modifier and Type | Method and Description |
---|---|
PersistentQueueSpec<T> |
basePath(String basePath) |
PersistentQueueSpec<T> |
clearOnStart(boolean clearOnStart) |
PersistentQueueSpec<T> |
codec(Codec<Buffer,T,T> codec) |
PersistentQueueSpec<T> |
dataBlockSize(int size) |
PersistentQueueSpec<T> |
deleteOnExit(boolean deleteOnExit) |
PersistentQueue<T> |
get()
Get an object.
|
PersistentQueueSpec<T> |
indexBlockSize(int indexBlockSize) |
PersistentQueueSpec<T> |
sync(boolean synchronousMode) |
public static String DEFAULT_BASE_PATH
public PersistentQueueSpec<T> basePath(String basePath)
public PersistentQueueSpec<T> clearOnStart(boolean clearOnStart)
public PersistentQueueSpec<T> deleteOnExit(boolean deleteOnExit)
public PersistentQueueSpec<T> dataBlockSize(int size)
public PersistentQueueSpec<T> sync(boolean synchronousMode)
public PersistentQueueSpec<T> indexBlockSize(int indexBlockSize)
public PersistentQueue<T> get()
Supplier
get
in interface Supplier<PersistentQueue<T>>
Copyright © 2017. All rights reserved.