public class UniversalRedisQueue extends RedisQueue
IQueue.
Queue and Take UniversalQueueMessages.
Implementation: see RedisQueue.
| Constructor and Description |
|---|
UniversalRedisQueue() |
| 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.
|
destroy, ephemeralSize, finish, getJedisPool, getOrphanMessages, getRedisHashName, getRedisHostAndPort, getRedisListName, getRedisSortedSetName, init, moveFromEphemeralToQueueStorage, queue, queueSize, remove, requeue, requeueSilent, setJedisPool, setRedisHashName, setRedisHostAndPort, setRedisListName, setRedisSortedSetName, storeNew, storeOldprotected byte[] serialize(IQueueMessage _msg)
serialize in class RedisQueueprotected UniversalQueueMessage deserialize(byte[] msgData)
deserialize in class RedisQueuepublic UniversalQueueMessage take()
Implementation flow:
Note: ephemeral storage implementation is optional, depends on implementation.
take in interface IQueuetake in class RedisQueueCopyright © 2015 DDTH. All Rights Reserved.