| Package | Description |
|---|---|
| com.github.ddth.queue |
| Modifier and Type | Method and Description |
|---|---|
UniversalQueueMessage |
UniversalQueueMessage.content(byte[] content)
Sets message's content.
|
static UniversalQueueMessage |
UniversalQueueMessage.newInstance()
Creates a new
UniversalQueueMessage object. |
UniversalQueueMessage |
UniversalQueueMessage.qId(Object queueId)
Sets message's unique queue id.
|
UniversalQueueMessage |
UniversalQueueMessage.qIncNumRequeues()
Increases message's number of re-queue times by 1.
|
UniversalQueueMessage |
UniversalQueueMessage.qNumRequeues(int numRequeues)
Sets message's number of re-queue times.
|
UniversalQueueMessage |
UniversalQueueMessage.qOriginalTimestamp(Date timestamp)
Sets message's first-queued timestamp.
|
UniversalQueueMessage |
UniversalQueueMessage.qTimestamp(Date timestamp)
Sets message's last-queued timestamp.
|
Copyright © 2015 DDTH. All Rights Reserved.