com.github.ddth.queue.impl.universal

Class UniversalRedisQueue

java.lang.Object

com.github.ddth.queue.impl.RedisQueue

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

com.github.ddth.queue.impl.universal.UniversalRedisQueue

All Implemented Interfaces:

IQueue, Closeable, AutoCloseable

public class UniversalRedisQueue
extends BaseUniversalRedisQueue<UniversalQueueMessage>

Universal Redis implementation of IQueue.

Queue and Take UniversalQueueMessages.

Implementation: see RedisQueue.

Since:

0.3.0

Author:

Thanh Ba Nguyen

Constructor Summary

Constructors

Constructor and Description
UniversalRedisQueue()

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.BaseUniversalRedisQueue

serialize, take

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

close, destroy, ephemeralSize, finish, getEphemeralDisabled, getJedisPool, getOrphanMessages, getRedisHashName, getRedisHostAndPort, getRedisListName, getRedisSortedSetName, init, isEphemeralDisabled, moveFromEphemeralToQueueStorage, queue, queueSize, remove, requeue, requeueSilent, setEphemeralDisabled, setJedisPool, setRedisHashName, setRedisHostAndPort, setRedisListName, setRedisSortedSetName, storeNew, storeOld

Methods inherited from class java.lang.Object

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

Constructor Detail

UniversalRedisQueue

public UniversalRedisQueue()

Method Detail

deserialize

protected UniversalQueueMessage deserialize(byte[] msgData)

Deserilizes a queue message.

Specified by:

deserialize in class RedisQueue

Returns: