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

Packages that use UniversalQueueMessage

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

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

Methods in com.github.ddth.queue.impl.universal 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.
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.
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	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.