Uses of Interface
com.github.ddth.queue.IQueueMessage

Packages that use IQueueMessage

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

Uses of IQueueMessage in com.github.ddth.queue

Classes in com.github.ddth.queue that implement IQueueMessage

Modifier and Type	Class and Description
class	UniversalQueueMessage Universal queue message.

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

Modifier and Type	Method and Description
IQueueMessage	IQueueMessage.qId(Object queueId) Sets message's unique queue id.
IQueueMessage	IQueueMessage.qIncNumRequeues() Increases message's number of re-queue times by 1.
IQueueMessage	IQueueMessage.qNumRequeues(int numRequeues) Sets message's number of re-queue times.
IQueueMessage	IQueueMessage.qOriginalTimestamp(Date timestamp) Sets message's first-queued timestamp.
IQueueMessage	IQueueMessage.qTimestamp(Date timestamp) Sets message's last-queued timestamp.
IQueueMessage	IQueue.take() Takes a message out of queue.

Methods in com.github.ddth.queue that return types with arguments of type IQueueMessage

Modifier and Type	Method and Description
Collection<IQueueMessage>	IQueue.getOrphanMessages(long thresholdTimestampMs) Gets all orphan messages (messages that were left in ephemeral storage for a long time).

Methods in com.github.ddth.queue with parameters of type IQueueMessage

Modifier and Type	Method and Description
void	IQueue.finish(IQueueMessage msg) Called when finish processing the message to cleanup ephemeral storage.
boolean	IQueue.moveFromEphemeralToQueueStorage(IQueueMessage msg) Moves a message from ephemeral back to queue storage.
boolean	IQueue.queue(IQueueMessage msg) Queues a message.
boolean	IQueue.requeue(IQueueMessage msg) Re-queues a message.
boolean	IQueue.requeueSilent(IQueueMessage msg) Silently re-queues a message.

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

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

Modifier and Type	Method and Description
protected IQueueMessage	JdbcQueue._takeWithRetries(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, int numRetries, int maxRetries) Takes a message from queue, retry if deadlock.
protected abstract IQueueMessage	JdbcQueue.readFromEphemeralStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, IQueueMessage msg) Reads a message from the ephemeral storage.
protected abstract IQueueMessage	JdbcQueue.readFromQueueStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate) Reads a message from head of queue storage.
IQueueMessage	JdbcQueue.take() Takes a message out of queue.

Methods in com.github.ddth.queue.impl that return types with arguments of type IQueueMessage

Modifier and Type	Method and Description
protected Collection<IQueueMessage>	JdbcQueue._getOrphanMessagesWithRetries(long thresholdTimestampMs, org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, int numRetries, int maxRetries) Gets all orphan messages (messages that were left in ephemeral storage for a long time), retry if deadlock.
protected abstract Collection<IQueueMessage>	JdbcQueue.getOrphanFromEphemeralStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, long thresholdTimestampMs) Gets all orphan messages (messages that were left in ephemeral storage for a long time).
Collection<IQueueMessage>	JdbcQueue.getOrphanMessages(long thresholdTimestampMs) Gets all orphan messages (messages that were left in ephemeral storage for a long time).

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

Modifier and Type	Method and Description
protected void	JdbcQueue._finishWithRetries(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, IQueueMessage msg, int numRetries, int maxRetries) Performs "finish" action, retry if deadlock.
protected boolean	JdbcQueue._moveFromEphemeralToQueueStorageWithRetries(IQueueMessage msg, org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, int numRetries, int maxRetries) Moves a message from ephemeral back to queue storage, retry if deadlock.
protected boolean	JdbcQueue._queueWithRetries(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, IQueueMessage msg, int numRetries, int maxRetries) Queues a message, retry if deadlock.
protected boolean	JdbcQueue._requeueSilentWithRetries(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, IQueueMessage msg, int numRetries, int maxRetries) Re-queues a message silently, retry if deadlock.
protected boolean	JdbcQueue._requeueWithRetries(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, IQueueMessage msg, int numRetries, int maxRetries) Re-queues a message, retry if deadlock.
void	JdbcQueue.finish(IQueueMessage msg) Called when finish processing the message to cleanup ephemeral storage.
boolean	JdbcQueue.moveFromEphemeralToQueueStorage(IQueueMessage msg) Moves a message from ephemeral back to queue storage.
protected abstract boolean	JdbcQueue.putToEphemeralStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, IQueueMessage msg) Puts a message to the ephemeral storage.
protected abstract boolean	JdbcQueue.putToQueueStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, IQueueMessage msg) Puts a message to tail of the queue storage.
boolean	JdbcQueue.queue(IQueueMessage msg) Queues a message.
protected abstract IQueueMessage	JdbcQueue.readFromEphemeralStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, IQueueMessage msg) Reads a message from the ephemeral storage.
protected abstract boolean	JdbcQueue.removeFromEphemeralStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, IQueueMessage msg) Removes a message from the ephemeral storage.
protected abstract boolean	JdbcQueue.removeFromQueueStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, IQueueMessage msg) Removes a message from the queue storage.
boolean	JdbcQueue.requeue(IQueueMessage msg) Re-queues a message.
boolean	JdbcQueue.requeueSilent(IQueueMessage msg) Silently re-queues a message.