com.github.ddth.queue.impl

Class RocksDbQueueFactory<T extends RocksDbQueue>

java.lang.Object

com.github.ddth.queue.impl.AbstractQueueFactory<T>

com.github.ddth.queue.impl.RocksDbQueueFactory<T>

All Implemented Interfaces:

IQueueFactory

Direct Known Subclasses:

UniversalRocksDbQueueFactory, UniversalRocksDbQueueFactory

public abstract class RocksDbQueueFactory<T extends RocksDbQueue>
extends AbstractQueueFactory<T>

Factory to create RocksDb instances.

Since:

0.4.1

Author:

Thanh Ba Nguyen

Field Summary

Fields

Modifier and Type	Field and Description
static String	SPEC_FIELD_CF_EPHEMERAL
static String	SPEC_FIELD_CF_METADATA
static String	SPEC_FIELD_CF_QUEUE
static String	SPEC_FIELD_STORAGE_DIR

Fields inherited from class com.github.ddth.queue.impl.AbstractQueueFactory

queueInstances

Constructor Summary

Constructors

Constructor and Description
RocksDbQueueFactory()

Method Summary

Modifier and Type	Method and Description
protected boolean	disposeQueue(T queue)
String	getDefaultStorageDir()
protected void	initQueue(T queue, QueueSpec spec) Initializes a newly created queue instance.
RocksDbQueueFactory<T>	setDefaultStorageDir(String defaultStorageDir)

Methods inherited from class com.github.ddth.queue.impl.AbstractQueueFactory

createAndInitQueue, createQueueInstance, destroy, disposeQueue, getQueue, init

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

SPEC_FIELD_STORAGE_DIR

public static final String SPEC_FIELD_STORAGE_DIR

See Also:

Constant Field Values

SPEC_FIELD_CF_EPHEMERAL

public static final String SPEC_FIELD_CF_EPHEMERAL

See Also:

Constant Field Values

SPEC_FIELD_CF_QUEUE

public static final String SPEC_FIELD_CF_QUEUE

See Also:

Constant Field Values

SPEC_FIELD_CF_METADATA

public static final String SPEC_FIELD_CF_METADATA

See Also:

Constant Field Values

Constructor Detail

RocksDbQueueFactory

public RocksDbQueueFactory()

Method Detail

getDefaultStorageDir

public String getDefaultStorageDir()

setDefaultStorageDir

public RocksDbQueueFactory<T> setDefaultStorageDir(String defaultStorageDir)

initQueue

protected void initQueue(T queue,
                         QueueSpec spec)

Initializes a newly created queue instance.

Called by AbstractQueueFactory.createAndInitQueue(QueueSpec). Sub-class may override this method to implement its own business logic.

Overrides:

initQueue in class AbstractQueueFactory<T extends RocksDbQueue>

disposeQueue

protected boolean disposeQueue(T queue)

Specified by:

disposeQueue in class AbstractQueueFactory<T extends RocksDbQueue>