Uses of Class
com.github.ddth.queue.impl.BaseUniversalQueueMessage

Packages that use BaseUniversalQueueMessage

Package	Description
com.github.ddth.queue.impl
com.github.ddth.queue.impl.universal

Uses of BaseUniversalQueueMessage in com.github.ddth.queue.impl

Classes in com.github.ddth.queue.impl with type parameters of type BaseUniversalQueueMessage

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.

Methods in com.github.ddth.queue.impl with type parameters of type BaseUniversalQueueMessage

Modifier and Type	Method and Description
static <T extends BaseUniversalQueueMessage> T	BaseUniversalQueueMessage.fromBytes(byte[] msgData, Class<T> clazz) Deserializes from a byte[] - which has been serialized by toBytes().

Methods in com.github.ddth.queue.impl that return BaseUniversalQueueMessage

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.

Uses of BaseUniversalQueueMessage in com.github.ddth.queue.impl.universal

Subclasses of BaseUniversalQueueMessage in com.github.ddth.queue.impl.universal

Modifier and Type	Class and Description
class	UniversalQueueMessage Extended from BaseUniversalQueueMessage where queue_id is a long.