com.github.ddth.queue.impl.universal

Class UniversalRocksDbQueueFactory

java.lang.Object

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

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

com.github.ddth.queue.impl.universal.UniversalRocksDbQueueFactory

All Implemented Interfaces:

IQueueFactory

public class UniversalRocksDbQueueFactory
extends RocksDbQueueFactory<UniversalRocksDbQueue>

Factory to create UniversalRocksDbQueue instances.

Since:

0.4.1

Author:

Thanh Ba Nguyen

Field Summary

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

SPEC_FIELD_CF_EPHEMERAL, SPEC_FIELD_CF_METADATA, SPEC_FIELD_CF_QUEUE, SPEC_FIELD_STORAGE_DIR

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

queueInstances

Constructor Summary

Constructors

Constructor and Description
UniversalRocksDbQueueFactory()

Method Summary

Modifier and Type	Method and Description
protected UniversalRocksDbQueue	createQueueInstance(QueueSpec spec) Creates a new queue instance.

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

disposeQueue, getDefaultStorageDir, initQueue, setDefaultStorageDir

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

createAndInitQueue, destroy, disposeQueue, getQueue, init

Methods inherited from class java.lang.Object

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

Constructor Detail

UniversalRocksDbQueueFactory

public UniversalRocksDbQueueFactory()

Method Detail

createQueueInstance

protected UniversalRocksDbQueue createQueueInstance(QueueSpec spec)

Creates a new queue instance.

Called by AbstractQueueFactory.createAndInitQueue(QueueSpec). Sub-class is to implement this method.

Specified by:

createQueueInstance in class AbstractQueueFactory<UniversalRocksDbQueue>

Returns: