| Package | Description |
|---|---|
| com.github.ddth.queue | |
| com.github.ddth.queue.impl |
| Modifier and Type | Class and Description |
|---|---|
class |
UniversalQueueMessage
Universal queue message.
|
| 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.
|
| 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).
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
protected IQueueMessage |
JdbcQueue._takeWithRetries(Connection conn,
int numRetries,
int maxRetries)
Takes a message from queue, retry if deadlock.
|
protected abstract IQueueMessage |
RedisQueue.deserialize(byte[] msgData)
Deserilizes a queue message.
|
protected abstract IQueueMessage |
KafkaQueue.deserialize(byte[] msgData)
Deserilizes a queue message.
|
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 |
RedisQueue.take()
Takes a message out of queue.
|
IQueueMessage |
KafkaQueue.take()
Takes a message out of queue.
|
IQueueMessage |
JdbcQueue.take()
Takes a message out of queue.
|
| Modifier and Type | Method and Description |
|---|---|
protected Collection<IQueueMessage> |
JdbcQueue._getOrphanMessagesWithRetries(long thresholdTimestampMs,
Connection conn,
int numRetries,
int maxRetries)
Gets all orphan messages (messages that were left in ephemeral storage
for a long time), retry if deadlock.
|
protected Collection<IQueueMessage> |
UniversalJdbcQueue.getOrphanFromEphemeralStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
long thresholdTimestampMs)
Gets all orphan messages (messages that were left in ephemeral storage
for a long time).
|
protected Collection<IQueueMessage> |
LessLockingUniversalPgSQLQueue.getOrphanFromEphemeralStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
long thresholdTimestampMs)
Gets all orphan messages (messages that were left in ephemeral storage
for a long time).
|
protected Collection<IQueueMessage> |
LessLockingUniversalMySQLQueue.getOrphanFromEphemeralStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
long thresholdTimestampMs)
Gets all orphan messages (messages that were left in ephemeral storage
for a long time).
|
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> |
RedisQueue.getOrphanMessages(long thresholdTimestampMs)
Gets all orphan messages (messages that were left in ephemeral storage
for a long time).
|
Collection<IQueueMessage> |
KafkaQueue.getOrphanMessages(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).
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
LessLockingUniversalPgSQLQueue._finishWithRetries(Connection conn,
IQueueMessage _msg,
int numRetries,
int maxRetries)
Performs "finish" action, retry if deadlock.
|
protected void |
LessLockingUniversalMySQLQueue._finishWithRetries(Connection conn,
IQueueMessage _msg,
int numRetries,
int maxRetries)
Performs "finish" action, retry if deadlock.
|
protected void |
JdbcQueue._finishWithRetries(Connection conn,
IQueueMessage msg,
int numRetries,
int maxRetries)
Performs "finish" action, retry if deadlock.
|
protected boolean |
LessLockingUniversalPgSQLQueue._moveFromEphemeralToQueueStorageWithRetries(IQueueMessage _msg,
Connection conn,
int numRetries,
int maxRetries)
Moves a message from ephemeral back to queue storage, retry if deadlock.
|
protected boolean |
LessLockingUniversalMySQLQueue._moveFromEphemeralToQueueStorageWithRetries(IQueueMessage _msg,
Connection conn,
int numRetries,
int maxRetries)
Moves a message from ephemeral back to queue storage, retry if deadlock.
|
protected boolean |
JdbcQueue._moveFromEphemeralToQueueStorageWithRetries(IQueueMessage msg,
Connection conn,
int numRetries,
int maxRetries)
Moves a message from ephemeral back to queue storage, retry if deadlock.
|
protected boolean |
LessLockingUniversalPgSQLQueue._queueWithRetries(Connection conn,
IQueueMessage _msg,
int numRetries,
int maxRetries)
Queues a message, retry if deadlock.
|
protected boolean |
LessLockingUniversalMySQLQueue._queueWithRetries(Connection conn,
IQueueMessage _msg,
int numRetries,
int maxRetries)
Queues a message, retry if deadlock.
|
protected boolean |
JdbcQueue._queueWithRetries(Connection conn,
IQueueMessage msg,
int numRetries,
int maxRetries)
Queues a message, retry if deadlock.
|
protected boolean |
LessLockingUniversalPgSQLQueue._requeueSilentWithRetries(Connection conn,
IQueueMessage _msg,
int numRetries,
int maxRetries)
Re-queues a message silently, retry if deadlock.
|
protected boolean |
LessLockingUniversalMySQLQueue._requeueSilentWithRetries(Connection conn,
IQueueMessage _msg,
int numRetries,
int maxRetries)
Re-queues a message silently, retry if deadlock.
|
protected boolean |
JdbcQueue._requeueSilentWithRetries(Connection conn,
IQueueMessage msg,
int numRetries,
int maxRetries)
Re-queues a message silently, retry if deadlock.
|
protected boolean |
LessLockingUniversalPgSQLQueue._requeueWithRetries(Connection conn,
IQueueMessage _msg,
int numRetries,
int maxRetries)
Re-queues a message, retry if deadlock.
|
protected boolean |
LessLockingUniversalMySQLQueue._requeueWithRetries(Connection conn,
IQueueMessage _msg,
int numRetries,
int maxRetries)
Re-queues a message, retry if deadlock.
|
protected boolean |
JdbcQueue._requeueWithRetries(Connection conn,
IQueueMessage msg,
int numRetries,
int maxRetries)
Re-queues a message, retry if deadlock.
|
void |
RedisQueue.finish(IQueueMessage msg)
Called when finish processing the message to cleanup ephemeral storage.
|
void |
KafkaQueue.finish(IQueueMessage msg)
Called when finish processing the message to cleanup ephemeral storage.
|
void |
JdbcQueue.finish(IQueueMessage msg)
Called when finish processing the message to cleanup ephemeral storage.
|
boolean |
RedisQueue.moveFromEphemeralToQueueStorage(IQueueMessage msg)
Moves a message from ephemeral back to queue storage.
|
boolean |
KafkaQueue.moveFromEphemeralToQueueStorage(IQueueMessage msg)
Moves a message from ephemeral back to queue storage.
|
boolean |
JdbcQueue.moveFromEphemeralToQueueStorage(IQueueMessage msg)
Moves a message from ephemeral back to queue storage.
|
protected boolean |
UniversalJdbcQueue.putToEphemeralStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
IQueueMessage _msg)
Puts a message to the ephemeral storage.
|
protected boolean |
LessLockingUniversalPgSQLQueue.putToEphemeralStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
IQueueMessage _msg)
Puts a message to the ephemeral storage.
|
protected boolean |
LessLockingUniversalMySQLQueue.putToEphemeralStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
IQueueMessage _msg)
Puts a message to the ephemeral storage.
|
protected abstract boolean |
JdbcQueue.putToEphemeralStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
IQueueMessage msg)
Puts a message to the ephemeral storage.
|
protected boolean |
KafkaQueue.putToQueue(IQueueMessage msg)
Puts a message to Kafka queue.
|
protected boolean |
UniversalJdbcQueue.putToQueueStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
IQueueMessage _msg)
Puts a message to tail of the queue storage.
|
protected boolean |
LessLockingUniversalPgSQLQueue.putToQueueStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
IQueueMessage _msg)
Puts a message to tail of the queue storage.
|
protected boolean |
LessLockingUniversalMySQLQueue.putToQueueStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
IQueueMessage _msg)
Puts a message to tail of the queue storage.
|
protected abstract boolean |
JdbcQueue.putToQueueStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
IQueueMessage msg)
Puts a message to tail of the queue storage.
|
boolean |
RedisQueue.queue(IQueueMessage msg)
Queues a message.
|
boolean |
KafkaQueue.queue(IQueueMessage msg)
Queues a message.
|
boolean |
JdbcQueue.queue(IQueueMessage msg)
Queues a 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 abstract IQueueMessage |
JdbcQueue.readFromEphemeralStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
IQueueMessage msg)
Reads a message from the ephemeral storage.
|
protected boolean |
RedisQueue.remove(IQueueMessage msg)
Removes a message completely.
|
protected boolean |
UniversalJdbcQueue.removeFromEphemeralStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
IQueueMessage _msg)
Removes a message from the ephemeral storage.
|
protected boolean |
LessLockingUniversalPgSQLQueue.removeFromEphemeralStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
IQueueMessage _msg)
Removes a message from the ephemeral storage.
|
protected boolean |
LessLockingUniversalMySQLQueue.removeFromEphemeralStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
IQueueMessage _msg)
Removes 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 boolean |
UniversalJdbcQueue.removeFromQueueStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
IQueueMessage _msg)
Removes a message from the queue storage.
|
protected boolean |
LessLockingUniversalPgSQLQueue.removeFromQueueStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
IQueueMessage msg)
Removes a message from the queue storage.
|
protected boolean |
LessLockingUniversalMySQLQueue.removeFromQueueStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
IQueueMessage msg)
Removes a message from the queue storage.
|
protected abstract boolean |
JdbcQueue.removeFromQueueStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
IQueueMessage msg)
Removes a message from the queue storage.
|
boolean |
RedisQueue.requeue(IQueueMessage msg)
Re-queues a message.
|
boolean |
KafkaQueue.requeue(IQueueMessage msg)
Re-queues a message.
|
boolean |
JdbcQueue.requeue(IQueueMessage msg)
Re-queues a message.
|
boolean |
RedisQueue.requeueSilent(IQueueMessage msg)
Silently re-queues a message.
|
boolean |
KafkaQueue.requeueSilent(IQueueMessage msg)
Silently re-queues a message.
|
boolean |
JdbcQueue.requeueSilent(IQueueMessage msg)
Silently re-queues a message.
|
protected byte[] |
UniversalRedisQueue.serialize(IQueueMessage _msg)
Serializes a queue message to store in Redis.
|
protected byte[] |
UniversalKafkaQueue.serialize(IQueueMessage _msg)
Serializes a queue message to store in Kafka.
|
protected abstract byte[] |
RedisQueue.serialize(IQueueMessage msg)
Serializes a queue message to store in Redis.
|
protected abstract byte[] |
KafkaQueue.serialize(IQueueMessage msg)
Serializes a queue message to store in Kafka.
|
protected boolean |
RedisQueue.storeNew(IQueueMessage msg)
Stores a new message.
|
protected boolean |
RedisQueue.storeOld(IQueueMessage msg)
Re-stores an old message (called by
RedisQueue.requeue(IQueueMessage) or
RedisQueue.requeueSilent(IQueueMessage). |
Copyright © 2015 DDTH. All Rights Reserved.