| Package | Description |
|---|---|
| com.github.ddth.queue.impl | |
| com.github.ddth.queue.impl.universal |
| Modifier and Type | Class and Description |
|---|---|
class |
RocksDbQueueFactory<T extends RocksDbQueue>
Factory to create
RocksDb instances. |
| Modifier and Type | Class and Description |
|---|---|
class |
BaseUniversalRocksDbQueue<T extends BaseUniversalQueueMessage>
Base class for universal RocksDB queue implementations.
|
| Modifier and Type | Method and Description |
|---|---|
RocksDbQueue |
RocksDbQueue.init()
Init method.
|
RocksDbQueue |
RocksDbQueue.setCfNameEphemeral(String cfNameEphemeral)
Sets name of the ColumnFamily to store ephemeral messages.
|
RocksDbQueue |
RocksDbQueue.setCfNameMetadata(String cfNameMetadata)
Sets name of the ColumnFamily to store metadata.
|
RocksDbQueue |
RocksDbQueue.setCfNameQueue(String cfNameQueue)
Sets name of the ColumnFamily to store queue messages.
|
RocksDbQueue |
RocksDbQueue.setEphemeralDisabled(boolean ephemeralDisabled)
Disables/Enables ephemeral storage.
|
RocksDbQueue |
RocksDbQueue.setStorageDir(String storageDir)
Sets RocksDB's storage directory.
|
| Modifier and Type | Class and Description |
|---|---|
class |
UniversalRocksDbQueue
Universal RocskDB implementation of
IQueue. |
Copyright © 2016 DDTH. All rights reserved.