| Package | Description |
|---|---|
| com.github.ddth.queue.impl | |
| com.github.ddth.queue.impl.universal |
| Modifier and Type | Class and Description |
|---|---|
class |
BaseUniversalKafkaQueue<T extends BaseUniversalQueueMessage>
Base class for universal Kafka queue implementation.
|
class |
BaseUniversalRedisQueue<T extends BaseUniversalQueueMessage>
Base class for universal Redis queue implementation.
|
| Modifier and Type | Method and Description |
|---|---|
static <T extends BaseUniversalQueueMessage> |
BaseUniversalQueueMessage.fromBytes(byte[] msgData,
Class<T> clazz)
Deserializes from a
byte[] - which has been serialized by
toBytes(). |
| Modifier and Type | Method and Description |
|---|---|
BaseUniversalQueueMessage |
BaseUniversalQueueMessage.content(byte[] content)
Sets message's content.
|
BaseUniversalQueueMessage |
BaseUniversalQueueMessage.content(String content)
Sets message's content.
|
BaseUniversalQueueMessage |
BaseUniversalQueueMessage.fromJson(String jsonString) |
BaseUniversalQueueMessage |
BaseUniversalQueueMessage.qIncNumRequeues()
Increases message's number of re-queue times by 1.
|
BaseUniversalQueueMessage |
BaseUniversalQueueMessage.qNumRequeues(int numRequeues)
Sets message's number of re-queue times.
|
BaseUniversalQueueMessage |
BaseUniversalQueueMessage.qOriginalTimestamp(Date timestamp)
Sets message's first-queued timestamp.
|
BaseUniversalQueueMessage |
BaseUniversalQueueMessage.qTimestamp(Date timestamp)
Sets message's last-queued timestamp.
|
| Modifier and Type | Class and Description |
|---|---|
class |
UniversalQueueMessage
|
Copyright © 2015 DDTH. All Rights Reserved.