Uses of Class
com.github.ddth.queue.UniversalQueueMessage

Packages that use UniversalQueueMessage

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

Uses of UniversalQueueMessage in com.github.ddth.queue

Methods in com.github.ddth.queue that return UniversalQueueMessage

Modifier and Type	Method and Description
UniversalQueueMessage	UniversalQueueMessage.content(byte[] content) Sets message's content.
static UniversalQueueMessage	UniversalQueueMessage.fromBytes(byte[] msgData) Deserializes from a byte[].
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.

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

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

Modifier and Type	Method and Description
protected UniversalQueueMessage	LessLockingUniversalPgSQLQueue._takeWithRetries(Connection conn, int numRetries, int maxRetries) Takes a message from queue, retry if deadlock.
protected UniversalQueueMessage	LessLockingUniversalMySQLQueue._takeWithRetries(Connection conn, int numRetries, int maxRetries) Takes a message from queue, retry if deadlock.
protected UniversalQueueMessage	UniversalRedisQueue.deserialize(byte[] msgData) Deserilizes a queue message.
protected UniversalQueueMessage	UniversalKafkaQueue.deserialize(byte[] msgData) Deserilizes a queue message.
protected UniversalQueueMessage	UniversalJdbcQueue.readFromEphemeralStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, IQueueMessage msg) Reads a message from the ephemeral storage.
protected UniversalQueueMessage	LessLockingUniversalPgSQLQueue.readFromEphemeralStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, IQueueMessage msg) Reads a message from the ephemeral storage.
protected UniversalQueueMessage	LessLockingUniversalMySQLQueue.readFromEphemeralStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, IQueueMessage msg) Reads a message from the ephemeral storage.
protected UniversalQueueMessage	UniversalJdbcQueue.readFromQueueStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate) Reads a message from head of queue storage.
protected UniversalQueueMessage	LessLockingUniversalPgSQLQueue.readFromQueueStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate) Reads a message from head of queue storage.
protected UniversalQueueMessage	LessLockingUniversalMySQLQueue.readFromQueueStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate) Reads a message from head of queue storage.
UniversalQueueMessage	UniversalRedisQueue.take() Takes a message out of queue.
UniversalQueueMessage	UniversalKafkaQueue.take() Takes a message out of queue.
UniversalQueueMessage	UniversalJdbcQueue.take() Takes a message out of queue.
UniversalQueueMessage	LessLockingUniversalPgSQLQueue.take() Takes a message out of queue.
UniversalQueueMessage	LessLockingUniversalMySQLQueue.take() Takes a message out of queue.