| Package | Description |
|---|---|
| com.github.ddth.queue | |
| com.github.ddth.queue.impl | |
| com.github.ddth.queue.impl.universal | |
| com.github.ddth.queue.impl.universal2 |
| Modifier and Type | Class and Description |
|---|---|
static class |
IQueueMessage.EmptyQueueMessage
An empty queue message.
|
| Modifier and Type | Method and Description |
|---|---|
IQueueMessage |
IQueueMessage.clone()
Clones this message.
|
IQueueMessage |
IQueueMessage.qData(Object data)
Attaches data/content to the queue message.
|
IQueueMessage |
IQueueMessage.EmptyQueueMessage.qData(Object data) |
IQueueMessage |
IQueueMessage.qId(Object queueId)
Sets message's unique queue id.
|
IQueueMessage |
IQueueMessage.EmptyQueueMessage.qId(Object queueId) |
IQueueMessage |
IQueueMessage.qIncNumRequeues()
Increases message's number of re-queue times by 1.
|
IQueueMessage |
IQueueMessage.EmptyQueueMessage.qIncNumRequeues() |
IQueueMessage |
IQueueMessage.qNumRequeues(int numRequeues)
Sets message's number of re-queue times.
|
IQueueMessage |
IQueueMessage.EmptyQueueMessage.qNumRequeues(int numRequeues) |
IQueueMessage |
IQueueMessage.qOriginalTimestamp(Date timestamp)
Sets message's first-queued timestamp.
|
IQueueMessage |
IQueueMessage.EmptyQueueMessage.qOriginalTimestamp(Date timestamp) |
IQueueMessage |
IQueueMessage.qTimestamp(Date timestamp)
Sets message's last-queued timestamp.
|
IQueueMessage |
IQueueMessage.EmptyQueueMessage.qTimestamp(Date 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 | Class and Description |
|---|---|
class |
BaseUniversalQueueMessage
Base class for universal queue messages.
|
| 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 |
RocksDbQueue.deserialize(byte[] msgData)
Deserilizes a queue message.
|
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 |
RocksDbQueue.take()
Takes a message out of queue.
|
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.
|
IQueueMessage |
InmemQueue.take()
Takes a message out of queue.
|
IQueueMessage |
DisruptorQueue.take()
Takes a message out of queue.
|
protected IQueueMessage |
KafkaQueue.takeFromQueue()
Takes a message from Kafka queue.
|
protected IQueueMessage |
InmemQueue.takeFromQueue()
Takes a message from the internal queue.
|
protected IQueueMessage |
DisruptorQueue.takeFromRingBuffer()
Takes a message from the ring buffer.
|
| 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 Queue<IQueueMessage> |
InmemQueue.createQueue(int boundary)
This method will create a
Queue instance with the following
rules:
If InmemQueue.boundary is set and larger than 1024, a
LinkedBlockingQueue is created; if InmemQueue.boundary is less than
or equals to 1024, an ArrayBlockingQueue is created
instead.
Otherwise, a ConcurrentLinkedQueue is created.
|
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> |
RocksDbQueue.getOrphanMessages(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).
|
Collection<IQueueMessage> |
InmemQueue.getOrphanMessages(long thresholdTimestampMs)
Gets all orphan messages (messages that were left in ephemeral storage
for a long time).
|
Collection<IQueueMessage> |
DisruptorQueue.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 |
JdbcQueue._finishWithRetries(Connection conn,
IQueueMessage msg,
int numRetries,
int maxRetries)
Performs "finish" action, 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 |
JdbcQueue._queueWithRetries(Connection conn,
IQueueMessage msg,
int numRetries,
int maxRetries)
Queues a message, 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 |
JdbcQueue._requeueWithRetries(Connection conn,
IQueueMessage msg,
int numRetries,
int maxRetries)
Re-queues a message, retry if deadlock.
|
void |
RocksDbQueue.finish(IQueueMessage msg)
Called when finish processing the message to cleanup ephemeral storage.
|
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.
|
void |
InmemQueue.finish(IQueueMessage msg)
Called when finish processing the message to cleanup ephemeral storage.
|
void |
DisruptorQueue.finish(IQueueMessage msg)
Called when finish processing the message to cleanup ephemeral storage.
|
boolean |
RocksDbQueue.moveFromEphemeralToQueueStorage(IQueueMessage msg)
Moves a message from ephemeral back to queue 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.
|
boolean |
InmemQueue.moveFromEphemeralToQueueStorage(IQueueMessage _msg)
Moves a message from ephemeral back to queue storage.
|
boolean |
DisruptorQueue.moveFromEphemeralToQueueStorage(IQueueMessage _msg)
Moves a message from ephemeral back to queue storage.
|
protected void |
DisruptorQueue.publish(IQueueMessage value,
long seq)
Publishes (commits) the ring's sequence.
|
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, partitioning message by
qId() |
protected boolean |
InmemQueue.putToQueue(IQueueMessage msg)
Puts a message to the internal queue.
|
protected boolean |
BaseUniversalKafkaQueue.putToQueue(IQueueMessage msg)
Puts a message to Kafka queue, partitioning message by
BaseUniversalQueueMessage.partitionKey() (or
qId() if message is not of type
BaseUniversalQueueMessage)). |
protected boolean |
RocksDbQueue.putToQueue(IQueueMessage msg,
boolean removeFromEphemeral) |
protected abstract boolean |
JdbcQueue.putToQueueStorage(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
IQueueMessage msg)
Puts a message to tail of the queue storage.
|
protected boolean |
DisruptorQueue.putToRingBuffer(IQueueMessage msg)
Puts a message to the ring buffer.
|
boolean |
RocksDbQueue.queue(IQueueMessage _msg)
Queues a message.
|
boolean |
RedisQueue.queue(IQueueMessage _msg)
Queues a message.
|
boolean |
KafkaQueue.queue(IQueueMessage _msg)
Queues a message.
|
boolean |
JdbcQueue.queue(IQueueMessage msg)
Queues a message.
|
boolean |
InmemQueue.queue(IQueueMessage _msg)
Queues a message.
|
boolean |
DisruptorQueue.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 boolean |
RedisQueue.remove(IQueueMessage msg)
Removes a message completely.
|
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 |
RocksDbQueue.requeue(IQueueMessage _msg)
Re-queues a message.
|
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 |
InmemQueue.requeue(IQueueMessage _msg)
Re-queues a message.
|
boolean |
DisruptorQueue.requeue(IQueueMessage _msg)
Re-queues a message.
|
boolean |
RocksDbQueue.requeueSilent(IQueueMessage msg)
Silently 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.
|
boolean |
InmemQueue.requeueSilent(IQueueMessage msg)
Silently re-queues a message.
|
boolean |
DisruptorQueue.requeueSilent(IQueueMessage msg)
Silently re-queues a message.
|
protected abstract byte[] |
RocksDbQueue.serialize(IQueueMessage msg)
Serializes a queue message to byte[].
|
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 byte[] |
BaseUniversalRocksDbQueue.serialize(IQueueMessage _msg)
Serializes a queue message to byte[].
|
protected byte[] |
BaseUniversalRedisQueue.serialize(IQueueMessage _msg)
Serializes a queue message to store in Redis.
|
protected byte[] |
BaseUniversalKafkaQueue.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). |
| Modifier and Type | Class and Description |
|---|---|
class |
UniversalQueueMessage
|
| Modifier and Type | Method and Description |
|---|---|
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).
|
| 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 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 |
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 |
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 |
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 |
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 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 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 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 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.
|
| Modifier and Type | Method and Description |
|---|---|
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).
|
| 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 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 |
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 |
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 |
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 |
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 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 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 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 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.
|
Copyright © 2016 DDTH. All rights reserved.