com.github.ddth.queue.impl.universal

Class UniversalRocksDbQueue

java.lang.Object

com.github.ddth.queue.impl.RocksDbQueue

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

com.github.ddth.queue.impl.universal.UniversalRocksDbQueue

All Implemented Interfaces:

IQueue, Closeable, AutoCloseable

public class UniversalRocksDbQueue
extends BaseUniversalRocksDbQueue<UniversalQueueMessage>

Universal RocskDB implementation of IQueue.

Queue and Take UniversalQueueMessages.

Implementation: see RocksDbQueue.

Since:

0.4.0

Author:

Thanh Ba Nguyen

Constructor Summary

Constructors

Constructor and Description
UniversalRocksDbQueue()

Method Summary

Modifier and Type	Method and Description
protected UniversalQueueMessage	deserialize(byte[] msgData) Deserilizes a queue message.

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

serialize, take

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

close, 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

UniversalRocksDbQueue

public UniversalRocksDbQueue()

Method Detail

deserialize

protected UniversalQueueMessage deserialize(byte[] msgData)

Deserilizes a queue message.

Specified by:

deserialize in class RocksDbQueue

Returns: