com.github.ddth.queue.impl

Class UniversalRedisQueue

java.lang.Object

com.github.ddth.queue.impl.RedisQueue

com.github.ddth.queue.impl.UniversalRedisQueue

All Implemented Interfaces:

IQueue

public class UniversalRedisQueue
extends RedisQueue

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

Methods

Modifier and Type	Method and Description
protected UniversalQueueMessage	deserialize(byte[] msgData) Deserilizes a queue message.
protected byte[]	serialize(IQueueMessage _msg) Serializes a queue message to store in Redis.
UniversalQueueMessage	take() Takes a message out of queue.

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

destroy, ephemeralSize, finish, getJedisPool, getOrphanMessages, getRedisHashName, getRedisHostAndPort, getRedisListName, getRedisSortedSetName, init, moveFromEphemeralToQueueStorage, queue, queueSize, remove, requeue, requeueSilent, 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

serialize

protected byte[] serialize(IQueueMessage _msg)

Serializes a queue message to store in Redis.

Specified by:

serialize in class RedisQueue

Returns:

deserialize

protected UniversalQueueMessage deserialize(byte[] msgData)

Deserilizes a queue message.

Specified by:

deserialize in class RedisQueue

Returns:

take

public UniversalQueueMessage 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 RedisQueue

Returns: