C D E F G I J K L M N P Q R S T U _

C

COL_CONTENT - Static variable in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

COL_CONTENT - Static variable in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

COL_CONTENT - Static variable in class com.github.ddth.queue.impl.UniversalJdbcQueue

COL_EPHEMERAL_ID - Static variable in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

COL_EPHEMERAL_ID - Static variable in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

COL_NUM_REQUEUES - Static variable in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

COL_NUM_REQUEUES - Static variable in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

COL_NUM_REQUEUES - Static variable in class com.github.ddth.queue.impl.UniversalJdbcQueue

COL_ORG_TIMESTAMP - Static variable in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

COL_ORG_TIMESTAMP - Static variable in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

COL_ORG_TIMESTAMP - Static variable in class com.github.ddth.queue.impl.UniversalJdbcQueue

COL_QUEUE_ID - Static variable in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

COL_QUEUE_ID - Static variable in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

COL_QUEUE_ID - Static variable in class com.github.ddth.queue.impl.UniversalJdbcQueue

COL_TIMESTAMP - Static variable in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

COL_TIMESTAMP - Static variable in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

COL_TIMESTAMP - Static variable in class com.github.ddth.queue.impl.UniversalJdbcQueue

com.github.ddth.queue - package com.github.ddth.queue

com.github.ddth.queue.impl - package com.github.ddth.queue.impl

com.github.ddth.queue.utils - package com.github.ddth.queue.utils

content() - Method in class com.github.ddth.queue.UniversalQueueMessage

Gets message's content.

content(byte[]) - Method in class com.github.ddth.queue.UniversalQueueMessage

Sets message's content.

D

DEFAULT_MAX_RETRIES - Static variable in class com.github.ddth.queue.impl.JdbcQueue

deserialize(byte[]) - Method in class com.github.ddth.queue.impl.KafkaQueue

Deserilizes a queue message.

deserialize(byte[]) - Method in class com.github.ddth.queue.impl.RedisQueue

Deserilizes a queue message.

deserialize(byte[]) - Method in class com.github.ddth.queue.impl.UniversalKafkaQueue

Deserilizes a queue message.

deserialize(byte[]) - Method in class com.github.ddth.queue.impl.UniversalRedisQueue

Deserilizes a queue message.

destroy() - Method in class com.github.ddth.queue.impl.JdbcQueue

destroy() - Method in class com.github.ddth.queue.impl.KafkaQueue

Destroy method.

destroy() - Method in class com.github.ddth.queue.impl.RedisQueue

Destroy method.

E

ephemeralSize() - Method in class com.github.ddth.queue.impl.JdbcQueue

Gets ephemeral-storage's number of items.

ephemeralSize() - Method in class com.github.ddth.queue.impl.KafkaQueue

Gets ephemeral-storage's number of items.

ephemeralSize() - Method in class com.github.ddth.queue.impl.RedisQueue

Gets ephemeral-storage's number of items.

ephemeralSize() - Method in interface com.github.ddth.queue.IQueue

Gets ephemeral-storage's number of items.

F

FIELD_CONTENT - Static variable in class com.github.ddth.queue.UniversalQueueMessage

FIELD_NUM_REQUEUES - Static variable in class com.github.ddth.queue.UniversalQueueMessage

FIELD_ORG_TIMESTAMP - Static variable in class com.github.ddth.queue.UniversalQueueMessage

FIELD_QUEUE_ID - Static variable in class com.github.ddth.queue.UniversalQueueMessage

FIELD_TIMESTAMP - Static variable in class com.github.ddth.queue.UniversalQueueMessage

finish(IQueueMessage) - Method in class com.github.ddth.queue.impl.JdbcQueue

Called when finish processing the message to cleanup ephemeral storage.

finish(IQueueMessage) - Method in class com.github.ddth.queue.impl.KafkaQueue

Called when finish processing the message to cleanup ephemeral storage.

finish(IQueueMessage) - Method in class com.github.ddth.queue.impl.RedisQueue

Called when finish processing the message to cleanup ephemeral storage.

finish(IQueueMessage) - Method in interface com.github.ddth.queue.IQueue

Called when finish processing the message to cleanup ephemeral storage.

fromBytes(byte[]) - Static method in class com.github.ddth.queue.UniversalQueueMessage

Deserializes from a byte[].

G

getEphemeralDisabled() - Method in class com.github.ddth.queue.impl.UniversalJdbcQueue

getFifo() - Method in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

getFifo() - Method in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

getFifo() - Method in class com.github.ddth.queue.impl.UniversalJdbcQueue

getJedisPool() - Method in class com.github.ddth.queue.impl.RedisQueue

getKafkaClient() - Method in class com.github.ddth.queue.impl.KafkaQueue

getMaxRetries() - Method in class com.github.ddth.queue.impl.JdbcQueue

getOrphanFromEphemeralStorage(JdbcTemplate, long) - Method in class com.github.ddth.queue.impl.JdbcQueue

Gets all orphan messages (messages that were left in ephemeral storage for a long time).

getOrphanFromEphemeralStorage(JdbcTemplate, long) - Method in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

Gets all orphan messages (messages that were left in ephemeral storage for a long time).

getOrphanFromEphemeralStorage(JdbcTemplate, long) - Method in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

Gets all orphan messages (messages that were left in ephemeral storage for a long time).

getOrphanFromEphemeralStorage(JdbcTemplate, long) - Method in class com.github.ddth.queue.impl.UniversalJdbcQueue

Gets all orphan messages (messages that were left in ephemeral storage for a long time).

getOrphanMessages(long) - Method in class com.github.ddth.queue.impl.JdbcQueue

Gets all orphan messages (messages that were left in ephemeral storage for a long time).

getOrphanMessages(long) - Method in class com.github.ddth.queue.impl.KafkaQueue

Gets all orphan messages (messages that were left in ephemeral storage for a long time).

getOrphanMessages(long) - Method in class com.github.ddth.queue.impl.RedisQueue

Gets all orphan messages (messages that were left in ephemeral storage for a long time).

getOrphanMessages(long) - Method in interface com.github.ddth.queue.IQueue

Gets all orphan messages (messages that were left in ephemeral storage for a long time).

getProducerType() - Method in class com.github.ddth.queue.impl.KafkaQueue

getRedisHashName() - Method in class com.github.ddth.queue.impl.RedisQueue

getRedisHostAndPort() - Method in class com.github.ddth.queue.impl.RedisQueue

Redis' host and port scheme (format host:port).

getRedisListName() - Method in class com.github.ddth.queue.impl.RedisQueue

getRedisSortedSetName() - Method in class com.github.ddth.queue.impl.RedisQueue

getTableName() - Method in class com.github.ddth.queue.impl.JdbcQueue

getTableNameEphemeral() - Method in class com.github.ddth.queue.impl.JdbcQueue

getTableNameEphemeral() - Method in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

getTableNameEphemeral() - Method in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

getTopicName() - Method in class com.github.ddth.queue.impl.KafkaQueue

getTransactionIsolationLevel() - Method in class com.github.ddth.queue.impl.JdbcQueue

getZkConnString() - Method in class com.github.ddth.queue.impl.KafkaQueue

Zookeeper connection string (format host1:port1,host2:port2,host3:port3/path).

I

init() - Method in class com.github.ddth.queue.impl.JdbcQueue

init() - Method in class com.github.ddth.queue.impl.KafkaQueue

Init method.

init() - Method in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

init() - Method in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

init() - Method in class com.github.ddth.queue.impl.RedisQueue

Init method.

init() - Method in class com.github.ddth.queue.impl.UniversalJdbcQueue

IQueue - Interface in com.github.ddth.queue

APIs to interact with queue.

IQueueMessage - Interface in com.github.ddth.queue

Represents a queue message.

isEphemeralDisabled() - Method in class com.github.ddth.queue.impl.UniversalJdbcQueue

isFifo() - Method in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

isFifo() - Method in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

isFifo() - Method in class com.github.ddth.queue.impl.UniversalJdbcQueue

J

JdbcQueue - Class in com.github.ddth.queue.impl

Abstract JDBC implementation of IQueue.

JdbcQueue() - Constructor for class com.github.ddth.queue.impl.JdbcQueue

K

KafkaQueue - Class in com.github.ddth.queue.impl

(Experimental) Kafka implementation of IQueue.

KafkaQueue() - Constructor for class com.github.ddth.queue.impl.KafkaQueue

L

LessLockingUniversalMySQLQueue - Class in com.github.ddth.queue.impl

Same as UniversalJdbcQueue, but using a less-locking algorithm - specific for MySQL, and requires onle one single db table for both queue and ephemeral storages.

LessLockingUniversalMySQLQueue() - Constructor for class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

LessLockingUniversalPgSQLQueue - Class in com.github.ddth.queue.impl

Same as UniversalJdbcQueue, but using a less-locking algorithm - specific for PgSQL, and requires only one single db table for both queue and ephemeral storages.

LessLockingUniversalPgSQLQueue() - Constructor for class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

M

markEphemeralDisabled(boolean) - Method in class com.github.ddth.queue.impl.UniversalJdbcQueue

markFifo(boolean) - Method in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

markFifo(boolean) - Method in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

markFifo(boolean) - Method in class com.github.ddth.queue.impl.UniversalJdbcQueue

moveFromEphemeralToQueueStorage(IQueueMessage) - Method in class com.github.ddth.queue.impl.JdbcQueue

Moves a message from ephemeral back to queue storage.

moveFromEphemeralToQueueStorage(IQueueMessage) - Method in class com.github.ddth.queue.impl.KafkaQueue

Moves a message from ephemeral back to queue storage.

moveFromEphemeralToQueueStorage(IQueueMessage) - Method in class com.github.ddth.queue.impl.RedisQueue

Moves a message from ephemeral back to queue storage.

moveFromEphemeralToQueueStorage(IQueueMessage) - Method in interface com.github.ddth.queue.IQueue

Moves a message from ephemeral back to queue storage.

N

newInstance() - Static method in class com.github.ddth.queue.UniversalQueueMessage

Creates a new UniversalQueueMessage object.

P

putToEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.JdbcQueue

Puts a message to the ephemeral storage.

putToEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

Puts a message to the ephemeral storage.

putToEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

Puts a message to the ephemeral storage.

putToEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.UniversalJdbcQueue

Puts a message to the ephemeral storage.

putToQueue(IQueueMessage) - Method in class com.github.ddth.queue.impl.KafkaQueue

Puts a message to Kafka queue.

putToQueueStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.JdbcQueue

Puts a message to tail of the queue storage.

putToQueueStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

Puts a message to tail of the queue storage.

putToQueueStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

Puts a message to tail of the queue storage.

putToQueueStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.UniversalJdbcQueue

Puts a message to tail of the queue storage.

Q

qId() - Method in interface com.github.ddth.queue.IQueueMessage

Message's unique id in queue.

qId(Object) - Method in interface com.github.ddth.queue.IQueueMessage

Sets message's unique queue id.

qId() - Method in class com.github.ddth.queue.UniversalQueueMessage

Message's unique id in queue.

qId(Object) - Method in class com.github.ddth.queue.UniversalQueueMessage

Sets message's unique queue id.

qIncNumRequeues() - Method in interface com.github.ddth.queue.IQueueMessage

Increases message's number of re-queue times by 1.

qIncNumRequeues() - Method in class com.github.ddth.queue.UniversalQueueMessage

Increases message's number of re-queue times by 1.

qNumRequeues() - Method in interface com.github.ddth.queue.IQueueMessage

How many times message has been re-queued?

qNumRequeues(int) - Method in interface com.github.ddth.queue.IQueueMessage

Sets message's number of re-queue times.

qNumRequeues() - Method in class com.github.ddth.queue.UniversalQueueMessage

qNumRequeues(int) - Method in class com.github.ddth.queue.UniversalQueueMessage

Sets message's number of re-queue times.

qOriginalTimestamp() - Method in interface com.github.ddth.queue.IQueueMessage

Message's first-queued timestamp.

qOriginalTimestamp(Date) - Method in interface com.github.ddth.queue.IQueueMessage

Sets message's first-queued timestamp.

qOriginalTimestamp() - Method in class com.github.ddth.queue.UniversalQueueMessage

Message's first-queued timestamp.

qOriginalTimestamp(Date) - Method in class com.github.ddth.queue.UniversalQueueMessage

Sets message's first-queued timestamp.

qTimestamp() - Method in interface com.github.ddth.queue.IQueueMessage

Message's last-queued timestamp.

qTimestamp(Date) - Method in interface com.github.ddth.queue.IQueueMessage

Sets message's last-queued timestamp.

qTimestamp() - Method in class com.github.ddth.queue.UniversalQueueMessage

Message's last-queued timestamp.

qTimestamp(Date) - Method in class com.github.ddth.queue.UniversalQueueMessage

Sets message's last-queued timestamp.

queue(IQueueMessage) - Method in class com.github.ddth.queue.impl.JdbcQueue

Queues a message.

queue(IQueueMessage) - Method in class com.github.ddth.queue.impl.KafkaQueue

Queues a message.

queue(IQueueMessage) - Method in class com.github.ddth.queue.impl.RedisQueue

Queues a message.

queue(IQueueMessage) - Method in interface com.github.ddth.queue.IQueue

Queues a message.

QueueException - Exception in com.github.ddth.queue.utils

Thrown to indicate that there has been an error with queue oeration.

QueueException() - Constructor for exception com.github.ddth.queue.utils.QueueException

QueueException(String) - Constructor for exception com.github.ddth.queue.utils.QueueException

QueueException(Throwable) - Constructor for exception com.github.ddth.queue.utils.QueueException

QueueException(String, Throwable) - Constructor for exception com.github.ddth.queue.utils.QueueException

QueueException(String, Throwable, boolean, boolean) - Constructor for exception com.github.ddth.queue.utils.QueueException

queueSize() - Method in class com.github.ddth.queue.impl.JdbcQueue

Gets queue's number of items.

queueSize() - Method in class com.github.ddth.queue.impl.KafkaQueue

Gets queue's number of items.

queueSize() - Method in class com.github.ddth.queue.impl.RedisQueue

Gets queue's number of items.

queueSize() - Method in interface com.github.ddth.queue.IQueue

Gets queue's number of items.

QueueUtils - Class in com.github.ddth.queue.utils

Utilities and Constants

QueueUtils() - Constructor for class com.github.ddth.queue.utils.QueueUtils

R

readFromEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.JdbcQueue

Reads a message from the ephemeral storage.

readFromEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

Reads a message from the ephemeral storage.

readFromEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

Reads a message from the ephemeral storage.

readFromEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.UniversalJdbcQueue

Reads a message from the ephemeral storage.

readFromQueueStorage(JdbcTemplate) - Method in class com.github.ddth.queue.impl.JdbcQueue

Reads a message from head of queue storage.

readFromQueueStorage(JdbcTemplate) - Method in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

Reads a message from head of queue storage.

readFromQueueStorage(JdbcTemplate) - Method in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

Reads a message from head of queue storage.

readFromQueueStorage(JdbcTemplate) - Method in class com.github.ddth.queue.impl.UniversalJdbcQueue

Reads a message from head of queue storage.

RedisQueue - Class in com.github.ddth.queue.impl

Redis implementation of IQueue.

RedisQueue() - Constructor for class com.github.ddth.queue.impl.RedisQueue

remove(IQueueMessage) - Method in class com.github.ddth.queue.impl.RedisQueue

Removes a message completely.

removeFromEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.JdbcQueue

Removes a message from the ephemeral storage.

removeFromEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

Removes a message from the ephemeral storage.

removeFromEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

Removes a message from the ephemeral storage.

removeFromEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.UniversalJdbcQueue

Removes a message from the ephemeral storage.

removeFromQueueStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.JdbcQueue

Removes a message from the queue storage.

removeFromQueueStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

Removes a message from the queue storage.

removeFromQueueStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

Removes a message from the queue storage.

removeFromQueueStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.UniversalJdbcQueue

Removes a message from the queue storage.

requeue(IQueueMessage) - Method in class com.github.ddth.queue.impl.JdbcQueue

Re-queues a message.

requeue(IQueueMessage) - Method in class com.github.ddth.queue.impl.KafkaQueue

Re-queues a message.

requeue(IQueueMessage) - Method in class com.github.ddth.queue.impl.RedisQueue

Re-queues a message.

requeue(IQueueMessage) - Method in interface com.github.ddth.queue.IQueue

Re-queues a message.

requeueSilent(IQueueMessage) - Method in class com.github.ddth.queue.impl.JdbcQueue

Silently re-queues a message.

requeueSilent(IQueueMessage) - Method in class com.github.ddth.queue.impl.KafkaQueue

Silently re-queues a message.

requeueSilent(IQueueMessage) - Method in class com.github.ddth.queue.impl.RedisQueue

Silently re-queues a message.

requeueSilent(IQueueMessage) - Method in interface com.github.ddth.queue.IQueue

Silently re-queues a message.

S

serialize(IQueueMessage) - Method in class com.github.ddth.queue.impl.KafkaQueue

Serializes a queue message to store in Kafka.

serialize(IQueueMessage) - Method in class com.github.ddth.queue.impl.RedisQueue

Serializes a queue message to store in Redis.

serialize(IQueueMessage) - Method in class com.github.ddth.queue.impl.UniversalKafkaQueue

Serializes a queue message to store in Kafka.

serialize(IQueueMessage) - Method in class com.github.ddth.queue.impl.UniversalRedisQueue

Serializes a queue message to store in Redis.

setEphemeralDisabled(boolean) - Method in class com.github.ddth.queue.impl.UniversalJdbcQueue

setFifo(boolean) - Method in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

setFifo(boolean) - Method in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

setFifo(boolean) - Method in class com.github.ddth.queue.impl.UniversalJdbcQueue

setJedisPool(JedisPool) - Method in class com.github.ddth.queue.impl.RedisQueue

setKafkaClient(KafkaClient) - Method in class com.github.ddth.queue.impl.KafkaQueue

setMaxRetries(int) - Method in class com.github.ddth.queue.impl.JdbcQueue

setProducerType(KafkaClient.ProducerType) - Method in class com.github.ddth.queue.impl.KafkaQueue

setRedisHashName(String) - Method in class com.github.ddth.queue.impl.RedisQueue

setRedisHostAndPort(String) - Method in class com.github.ddth.queue.impl.RedisQueue

Sets Redis' host and port scheme (format host:port).

setRedisListName(String) - Method in class com.github.ddth.queue.impl.RedisQueue

setRedisSortedSetName(String) - Method in class com.github.ddth.queue.impl.RedisQueue

setTableName(String) - Method in class com.github.ddth.queue.impl.JdbcQueue

setTableNameEphemeral(String) - Method in class com.github.ddth.queue.impl.JdbcQueue

setTopicName(String) - Method in class com.github.ddth.queue.impl.KafkaQueue

setTransactionIsolationLevel(int) - Method in class com.github.ddth.queue.impl.JdbcQueue

setZkConnString(String) - Method in class com.github.ddth.queue.impl.KafkaQueue

Sets Zookeeper connection string (format host1:port1,host2:port2,host3:port3/path).

storeNew(IQueueMessage) - Method in class com.github.ddth.queue.impl.RedisQueue

Stores a new message.

storeOld(IQueueMessage) - Method in class com.github.ddth.queue.impl.RedisQueue

Re-stores an old message (called by RedisQueue.requeue(IQueueMessage) or RedisQueue.requeueSilent(IQueueMessage).

T

take() - Method in class com.github.ddth.queue.impl.JdbcQueue

Takes a message out of queue.

take() - Method in class com.github.ddth.queue.impl.KafkaQueue

Takes a message out of queue.

take() - Method in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

Takes a message out of queue.

take() - Method in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

Takes a message out of queue.

take() - Method in class com.github.ddth.queue.impl.RedisQueue

Takes a message out of queue.

take() - Method in class com.github.ddth.queue.impl.UniversalJdbcQueue

Takes a message out of queue.

take() - Method in class com.github.ddth.queue.impl.UniversalKafkaQueue

Takes a message out of queue.

take() - Method in class com.github.ddth.queue.impl.UniversalRedisQueue

Takes a message out of queue.

take() - Method in interface com.github.ddth.queue.IQueue

Takes a message out of queue.

toBytes() - Method in class com.github.ddth.queue.UniversalQueueMessage

Serializes to byte[].

U

UniversalJdbcQueue - Class in com.github.ddth.queue.impl

Universal JDBC implementation of IQueue.

UniversalJdbcQueue() - Constructor for class com.github.ddth.queue.impl.UniversalJdbcQueue

UniversalKafkaQueue - Class in com.github.ddth.queue.impl

Universal Kafka implementation of IQueue.

UniversalKafkaQueue() - Constructor for class com.github.ddth.queue.impl.UniversalKafkaQueue

UniversalQueueMessage - Class in com.github.ddth.queue

Universal queue message.

UniversalQueueMessage() - Constructor for class com.github.ddth.queue.UniversalQueueMessage

UniversalRedisQueue - Class in com.github.ddth.queue.impl

Universal Redis implementation of IQueue.

UniversalRedisQueue() - Constructor for class com.github.ddth.queue.impl.UniversalRedisQueue

UTF8 - Static variable in class com.github.ddth.queue.utils.QueueUtils

_

_finishWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.JdbcQueue

Performs "finish" action, retry if deadlock.

_finishWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

Performs "finish" action, retry if deadlock.

_finishWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

Performs "finish" action, retry if deadlock.

_getOrphanMessagesWithRetries(long, Connection, int, int) - Method in class com.github.ddth.queue.impl.JdbcQueue

Gets all orphan messages (messages that were left in ephemeral storage for a long time), retry if deadlock.

_moveFromEphemeralToQueueStorageWithRetries(IQueueMessage, Connection, int, int) - Method in class com.github.ddth.queue.impl.JdbcQueue

Moves a message from ephemeral back to queue storage, retry if deadlock.

_moveFromEphemeralToQueueStorageWithRetries(IQueueMessage, Connection, int, int) - Method in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

Moves a message from ephemeral back to queue storage, retry if deadlock.

_moveFromEphemeralToQueueStorageWithRetries(IQueueMessage, Connection, int, int) - Method in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

Moves a message from ephemeral back to queue storage, retry if deadlock.

_queueWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.JdbcQueue

Queues a message, retry if deadlock.

_queueWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

Queues a message, retry if deadlock.

_queueWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

Queues a message, retry if deadlock.

_requeueSilentWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.JdbcQueue

Re-queues a message silently, retry if deadlock.

_requeueSilentWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

Re-queues a message silently, retry if deadlock.

_requeueSilentWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

Re-queues a message silently, retry if deadlock.

_requeueWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.JdbcQueue

Re-queues a message, retry if deadlock.

_requeueWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

Re-queues a message, retry if deadlock.

_requeueWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

Re-queues a message, retry if deadlock.

_takeWithRetries(Connection, int, int) - Method in class com.github.ddth.queue.impl.JdbcQueue

Takes a message from queue, retry if deadlock.

_takeWithRetries(Connection, int, int) - Method in class com.github.ddth.queue.impl.LessLockingUniversalMySQLQueue

Takes a message from queue, retry if deadlock.

_takeWithRetries(Connection, int, int) - Method in class com.github.ddth.queue.impl.LessLockingUniversalPgSQLQueue

Takes a message from queue, retry if deadlock.

C D E F G I J K L M N P Q R S T U _