public class UniversalRedisQueue extends BaseUniversalRedisQueue<UniversalQueueMessage>
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.
|
serialize, takedestroy, ephemeralSize, finish, getJedisPool, getOrphanMessages, getRedisHashName, getRedisHostAndPort, getRedisListName, getRedisSortedSetName, init, moveFromEphemeralToQueueStorage, queue, queueSize, remove, requeue, requeueSilent, setJedisPool, setRedisHashName, setRedisHostAndPort, setRedisListName, setRedisSortedSetName, storeNew, storeOldprotected UniversalQueueMessage deserialize(byte[] msgData)
deserialize in class RedisQueueCopyright © 2015 DDTH. All Rights Reserved.