com.github.ddth.queue.impl

Class BaseUniversalRocksDbQueue<T extends BaseUniversalQueueMessage>

java.lang.Object

com.github.ddth.queue.impl.RocksDbQueue

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

Type Parameters:

T -

All Implemented Interfaces:

IQueue, Closeable, AutoCloseable

Direct Known Subclasses:

UniversalRocksDbQueue, UniversalRocksDbQueue

public abstract class BaseUniversalRocksDbQueue<T extends BaseUniversalQueueMessage>
extends RocksDbQueue

Base class for universal RocksDB queue implementations.

Since:

0.4.0

Author:

Thanh Nguyen

Constructor Summary

Constructors

Constructor and Description
BaseUniversalRocksDbQueue()

Method Summary

Modifier and Type	Method and Description
protected byte[]	serialize(IQueueMessage _msg) Serializes a queue message to byte[].
T	take() Takes a message out of queue.

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

close, deserialize, destroy, ephemeralSize, finish, getCfEphemeral, getCfMetadata, getCfNameEphemeral, getCfNameMetadata, getCfNameQueue, getCfQueue, getEphemeralDisabled, getOrphanMessages, getReadOptions, getRocksDb, getStorageDir, getWriteOptions, init, isEphemeralDisabled, moveFromEphemeralToQueueStorage, putToQueue, queue, queueSize, requeue, requeueSilent, setCfNameEphemeral, setCfNameMetadata, setCfNameQueue, setEphemeralDisabled, setStorageDir

Methods inherited from class java.lang.Object

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

Constructor Detail

BaseUniversalRocksDbQueue

public BaseUniversalRocksDbQueue()

Method Detail

serialize

protected byte[] serialize(IQueueMessage _msg)
                    throws QueueException

Serializes a queue message to byte[].

Specified by:

serialize in class RocksDbQueue

Returns:

Throws:

QueueException

take

public T take()

Takes a message out of queue.

Implementation flow:

• Read message from head of queue storage.
• Write message to ephemeral storage.
• Remove message from queue storage.

Note: ephemeral storage implementation is optional, depends on implementation.

Specified by:

take in interface IQueue

Overrides:

take in class RocksDbQueue

Returns: