Index (ddth-queue-core 0.4.2 API)

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

A

AbstractQueueFactory<T extends IQueue> - Class in com.github.ddth.queue.impl
AbstractQueueFactory() - Constructor for class com.github.ddth.queue.impl.AbstractQueueFactory

B

BaseUniversalDisruptorQueue<T extends BaseUniversalQueueMessage> - Class in com.github.ddth.queue.impl: Base class for universal LMAX Disruptor queue implementations.
BaseUniversalDisruptorQueue() - Constructor for class com.github.ddth.queue.impl.BaseUniversalDisruptorQueue
BaseUniversalDisruptorQueue(int) - Constructor for class com.github.ddth.queue.impl.BaseUniversalDisruptorQueue
BaseUniversalInmemQueue<T extends BaseUniversalQueueMessage> - Class in com.github.ddth.queue.impl: Base class for universal in-memory queue implementations.
BaseUniversalInmemQueue() - Constructor for class com.github.ddth.queue.impl.BaseUniversalInmemQueue
BaseUniversalInmemQueue(int) - Constructor for class com.github.ddth.queue.impl.BaseUniversalInmemQueue
BaseUniversalKafkaQueue<T extends BaseUniversalQueueMessage> - Class in com.github.ddth.queue.impl: Base class for universal Kafka queue implementations.
BaseUniversalKafkaQueue() - Constructor for class com.github.ddth.queue.impl.BaseUniversalKafkaQueue
BaseUniversalQueueMessage - Class in com.github.ddth.queue.impl: Base class for universal queue messages.
BaseUniversalQueueMessage() - Constructor for class com.github.ddth.queue.impl.BaseUniversalQueueMessage
BaseUniversalRedisQueue<T extends BaseUniversalQueueMessage> - Class in com.github.ddth.queue.impl: Base class for universal Redis queue implementations.
BaseUniversalRedisQueue() - Constructor for class com.github.ddth.queue.impl.BaseUniversalRedisQueue
BaseUniversalRocksDbQueue<T extends BaseUniversalQueueMessage> - Class in com.github.ddth.queue.impl: Base class for universal RocksDB queue implementations.
BaseUniversalRocksDbQueue() - Constructor for class com.github.ddth.queue.impl.BaseUniversalRocksDbQueue

C

CannotDeserializeQueueMessage() - Constructor for exception com.github.ddth.queue.utils.QueueException.CannotDeserializeQueueMessage
CannotDeserializeQueueMessage(String) - Constructor for exception com.github.ddth.queue.utils.QueueException.CannotDeserializeQueueMessage
CannotDeserializeQueueMessage(Throwable) - Constructor for exception com.github.ddth.queue.utils.QueueException.CannotDeserializeQueueMessage
CannotDeserializeQueueMessage(String, Throwable) - Constructor for exception com.github.ddth.queue.utils.QueueException.CannotDeserializeQueueMessage
CannotDeserializeQueueMessage(String, Throwable, boolean, boolean) - Constructor for exception com.github.ddth.queue.utils.QueueException.CannotDeserializeQueueMessage
CannotSerializeQueueMessage() - Constructor for exception com.github.ddth.queue.utils.QueueException.CannotSerializeQueueMessage
CannotSerializeQueueMessage(String) - Constructor for exception com.github.ddth.queue.utils.QueueException.CannotSerializeQueueMessage
CannotSerializeQueueMessage(Throwable) - Constructor for exception com.github.ddth.queue.utils.QueueException.CannotSerializeQueueMessage
CannotSerializeQueueMessage(String, Throwable) - Constructor for exception com.github.ddth.queue.utils.QueueException.CannotSerializeQueueMessage
CannotSerializeQueueMessage(String, Throwable, boolean, boolean) - Constructor for exception com.github.ddth.queue.utils.QueueException.CannotSerializeQueueMessage
clone() - Method in class com.github.ddth.queue.impl.BaseUniversalQueueMessage: Clones this message.
clone() - Method in class com.github.ddth.queue.impl.universal.UniversalQueueMessage: Clones this message.
clone() - Method in class com.github.ddth.queue.impl.universal2.UniversalQueueMessage: Clones this message.
clone() - Method in interface com.github.ddth.queue.IQueueMessage: Clones this message.
clone() - Method in class com.github.ddth.queue.IQueueMessage.EmptyQueueMessage: Clones this message.
close() - Method in class com.github.ddth.queue.impl.DisruptorQueue
close() - Method in class com.github.ddth.queue.impl.InmemQueue
close() - Method in class com.github.ddth.queue.impl.JdbcQueue
close() - Method in class com.github.ddth.queue.impl.KafkaQueue
close() - Method in class com.github.ddth.queue.impl.RedisQueue
close() - Method in class com.github.ddth.queue.impl.RocksDbQueue
COL_CONTENT - Static variable in class com.github.ddth.queue.impl.universal.LessLockingUniversalMySQLQueue: Table's column name to store message's content
COL_CONTENT - Static variable in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue: Table's column name to store message's content
COL_CONTENT - Static variable in class com.github.ddth.queue.impl.universal.UniversalJdbcQueue: Table's column name to store message's content
COL_CONTENT - Static variable in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue: Table's column name to store message's content
COL_CONTENT - Static variable in class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueue: Table's column name to store message's content
COL_CONTENT - Static variable in class com.github.ddth.queue.impl.universal2.UniversalJdbcQueue: Table's column name to store message's content
COL_EPHEMERAL_ID - Static variable in class com.github.ddth.queue.impl.universal.LessLockingUniversalMySQLQueue: Table's column name to store ephemeral id
COL_EPHEMERAL_ID - Static variable in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue: Table's column name to store ephemeral id
COL_EPHEMERAL_ID - Static variable in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue: Table's column name to store ephemeral id
COL_EPHEMERAL_ID - Static variable in class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueue: Table's column name to store ephemeral id
COL_NUM_REQUEUES - Static variable in class com.github.ddth.queue.impl.universal.LessLockingUniversalMySQLQueue: Table's column name to store message's number of requeues
COL_NUM_REQUEUES - Static variable in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue: Table's column name to store message's number of requeues
COL_NUM_REQUEUES - Static variable in class com.github.ddth.queue.impl.universal.UniversalJdbcQueue: Table's column name to store message's number of requeues
COL_NUM_REQUEUES - Static variable in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue: Table's column name to store message's number of requeues
COL_NUM_REQUEUES - Static variable in class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueue: Table's column name to store message's number of requeues
COL_NUM_REQUEUES - Static variable in class com.github.ddth.queue.impl.universal2.UniversalJdbcQueue: Table's column name to store message's number of requeues
COL_ORG_TIMESTAMP - Static variable in class com.github.ddth.queue.impl.universal.LessLockingUniversalMySQLQueue: Table's column name to store message's original timestamp
COL_ORG_TIMESTAMP - Static variable in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue: Table's column name to store message's original timestamp
COL_ORG_TIMESTAMP - Static variable in class com.github.ddth.queue.impl.universal.UniversalJdbcQueue: Table's column name to store message's original timestamp
COL_ORG_TIMESTAMP - Static variable in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue: Table's column name to store message's original timestamp
COL_ORG_TIMESTAMP - Static variable in class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueue: Table's column name to store message's original timestamp
COL_ORG_TIMESTAMP - Static variable in class com.github.ddth.queue.impl.universal2.UniversalJdbcQueue: Table's column name to store message's original timestamp
COL_QUEUE_ID - Static variable in class com.github.ddth.queue.impl.universal.LessLockingUniversalMySQLQueue: Table's column name to store queue-id
COL_QUEUE_ID - Static variable in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue: Table's column name to store queue-id
COL_QUEUE_ID - Static variable in class com.github.ddth.queue.impl.universal.UniversalJdbcQueue: Table's column name to store queue-id
COL_QUEUE_ID - Static variable in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue: Table's column name to store queue-id
COL_QUEUE_ID - Static variable in class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueue: Table's column name to store queue-id
COL_QUEUE_ID - Static variable in class com.github.ddth.queue.impl.universal2.UniversalJdbcQueue: Table's column name to store queue-id
COL_TIMESTAMP - Static variable in class com.github.ddth.queue.impl.universal.LessLockingUniversalMySQLQueue: Table's column name to store message's timestamp
COL_TIMESTAMP - Static variable in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue: Table's column name to store message's timestamp
COL_TIMESTAMP - Static variable in class com.github.ddth.queue.impl.universal.UniversalJdbcQueue: Table's column name to store message's timestamp
COL_TIMESTAMP - Static variable in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue: Table's column name to store message's timestamp
COL_TIMESTAMP - Static variable in class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueue: Table's column name to store message's timestamp
COL_TIMESTAMP - Static variable in class com.github.ddth.queue.impl.universal2.UniversalJdbcQueue: Table's column name to store message's timestamp
com.github.ddth.queue - package com.github.ddth.queue
com.github.ddth.queue.impl - package com.github.ddth.queue.impl
com.github.ddth.queue.impl.universal - package com.github.ddth.queue.impl.universal
com.github.ddth.queue.impl.universal2 - package com.github.ddth.queue.impl.universal2
com.github.ddth.queue.utils - package com.github.ddth.queue.utils
content() - Method in class com.github.ddth.queue.impl.BaseUniversalQueueMessage: Gets message's content.
content(byte[]) - Method in class com.github.ddth.queue.impl.BaseUniversalQueueMessage: Sets message's content.
content(String) - Method in class com.github.ddth.queue.impl.BaseUniversalQueueMessage: Sets message's content.
contentAsString() - Method in class com.github.ddth.queue.impl.BaseUniversalQueueMessage: Gets message's content as a String.
createAndInitQueue(QueueSpec) - Method in class com.github.ddth.queue.impl.AbstractQueueFactory: Creates & Initializes a new queue instance.
createQueue(int) - Method in class com.github.ddth.queue.impl.InmemQueue: 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.
createQueueInstance(QueueSpec) - Method in class com.github.ddth.queue.impl.AbstractQueueFactory: Creates a new queue instance.
createQueueInstance(QueueSpec) - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalMySQLQueueFactory: Creates a new queue instance.
createQueueInstance(QueueSpec) - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueueFactory: Creates a new queue instance.
createQueueInstance(QueueSpec) - Method in class com.github.ddth.queue.impl.universal.UniversalDisruptorQueueFactory: Creates a new queue instance.
createQueueInstance(QueueSpec) - Method in class com.github.ddth.queue.impl.universal.UniversalInmemQueueFactory: Creates a new queue instance.
createQueueInstance(QueueSpec) - Method in class com.github.ddth.queue.impl.universal.UniversalJdbcQueueFactory: Creates a new queue instance.
createQueueInstance(QueueSpec) - Method in class com.github.ddth.queue.impl.universal.UniversalKafkaQueueFactory: Creates a new queue instance.
createQueueInstance(QueueSpec) - Method in class com.github.ddth.queue.impl.universal.UniversalRedisQueueFactory: Creates a new queue instance.
createQueueInstance(QueueSpec) - Method in class com.github.ddth.queue.impl.universal.UniversalRocksDbQueueFactory: Creates a new queue instance.
createQueueInstance(QueueSpec) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueueFactory: Creates a new queue instance.
createQueueInstance(QueueSpec) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueueFactory: Creates a new queue instance.
createQueueInstance(QueueSpec) - Method in class com.github.ddth.queue.impl.universal2.UniversalDisruptorQueueFactory: Creates a new queue instance.
createQueueInstance(QueueSpec) - Method in class com.github.ddth.queue.impl.universal2.UniversalInmemQueueFactory: Creates a new queue instance.
createQueueInstance(QueueSpec) - Method in class com.github.ddth.queue.impl.universal2.UniversalJdbcQueueFactory: Creates a new queue instance.
createQueueInstance(QueueSpec) - Method in class com.github.ddth.queue.impl.universal2.UniversalKafkaQueueFactory: Creates a new queue instance.
createQueueInstance(QueueSpec) - Method in class com.github.ddth.queue.impl.universal2.UniversalRedisQueueFactory: Creates a new queue instance.
createQueueInstance(QueueSpec) - Method in class com.github.ddth.queue.impl.universal2.UniversalRocksDbQueueFactory: Creates a new queue instance.

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.RocksDbQueue: Deserilizes a queue message.
deserialize(byte[]) - Method in class com.github.ddth.queue.impl.universal.UniversalKafkaQueue: Deserilizes a queue message.
deserialize(byte[]) - Method in class com.github.ddth.queue.impl.universal.UniversalRedisQueue: Deserilizes a queue message.
deserialize(byte[]) - Method in class com.github.ddth.queue.impl.universal.UniversalRocksDbQueue: Deserilizes a queue message.
deserialize(byte[]) - Method in class com.github.ddth.queue.impl.universal2.UniversalKafkaQueue: Deserilizes a queue message.
deserialize(byte[]) - Method in class com.github.ddth.queue.impl.universal2.UniversalRedisQueue: Deserilizes a queue message.
deserialize(byte[]) - Method in class com.github.ddth.queue.impl.universal2.UniversalRocksDbQueue: Deserilizes a queue message.
destroy() - Method in class com.github.ddth.queue.impl.AbstractQueueFactory
destroy() - Method in class com.github.ddth.queue.impl.DisruptorQueue: Destroy method.
destroy() - Method in class com.github.ddth.queue.impl.InmemQueue: Destroy method.
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.
destroy() - Method in class com.github.ddth.queue.impl.RocksDbQueue: Destroy method.
disposeQueue(T) - Method in class com.github.ddth.queue.impl.AbstractQueueFactory
disposeQueue(QueueSpec, T) - Method in class com.github.ddth.queue.impl.AbstractQueueFactory
disposeQueue(T) - Method in class com.github.ddth.queue.impl.DisruptorQueueFactory
disposeQueue(T) - Method in class com.github.ddth.queue.impl.InmemQueueFactory
disposeQueue(T) - Method in class com.github.ddth.queue.impl.JdbcQueueFactory
disposeQueue(T) - Method in class com.github.ddth.queue.impl.KafkaQueueFactory
disposeQueue(T) - Method in class com.github.ddth.queue.impl.RedisQueueFactory
disposeQueue(T) - Method in class com.github.ddth.queue.impl.RocksDbQueueFactory
DisruptorQueue - Class in com.github.ddth.queue.impl: In-Memory implementation of IQueue using LMAX Disruptor library.
DisruptorQueue() - Constructor for class com.github.ddth.queue.impl.DisruptorQueue
DisruptorQueue(int) - Constructor for class com.github.ddth.queue.impl.DisruptorQueue
DisruptorQueueFactory<T extends DisruptorQueue> - Class in com.github.ddth.queue.impl: Factory to create DisruptorQueue instances.
DisruptorQueueFactory() - Constructor for class com.github.ddth.queue.impl.DisruptorQueueFactory

E

EmptyQueueMessage() - Constructor for class com.github.ddth.queue.IQueueMessage.EmptyQueueMessage
ephemeralSize() - Method in class com.github.ddth.queue.impl.DisruptorQueue: Gets ephemeral-storage's number of items.
ephemeralSize() - Method in class com.github.ddth.queue.impl.InmemQueue: Gets ephemeral-storage's number of items.
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 class com.github.ddth.queue.impl.RocksDbQueue: Gets ephemeral-storage's number of items.
ephemeralSize() - Method in interface com.github.ddth.queue.IQueue: Gets ephemeral-storage's number of items.
equals(Object) - Method in class com.github.ddth.queue.QueueSpec

F

FIELD_CONTENT - Static variable in class com.github.ddth.queue.impl.BaseUniversalQueueMessage
FIELD_EPHEMERAL_DISABLED - Static variable in class com.github.ddth.queue.QueueSpec
FIELD_MAX_SIZE - Static variable in class com.github.ddth.queue.QueueSpec
FIELD_NUM_REQUEUES - Static variable in class com.github.ddth.queue.impl.BaseUniversalQueueMessage
FIELD_ORG_TIMESTAMP - Static variable in class com.github.ddth.queue.impl.BaseUniversalQueueMessage
FIELD_PARTITION_KEY - Static variable in class com.github.ddth.queue.impl.BaseUniversalQueueMessage: Key used for partitioning messages.
FIELD_QUEUE_ID - Static variable in class com.github.ddth.queue.impl.BaseUniversalQueueMessage
FIELD_TIMESTAMP - Static variable in class com.github.ddth.queue.impl.BaseUniversalQueueMessage
finish(IQueueMessage) - Method in class com.github.ddth.queue.impl.DisruptorQueue: Called when finish processing the message to cleanup ephemeral storage.
finish(IQueueMessage) - Method in class com.github.ddth.queue.impl.InmemQueue: Called when finish processing the message to cleanup ephemeral storage.
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 class com.github.ddth.queue.impl.RocksDbQueue: 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[], Class<T>) - Static method in class com.github.ddth.queue.impl.BaseUniversalQueueMessage: Deserializes from a byte[] - which has been serialized by BaseUniversalQueueMessage.toBytes().
fromBytes(byte[]) - Static method in class com.github.ddth.queue.impl.universal.UniversalQueueMessage: Deserializes from a byte[].
fromBytes(byte[]) - Static method in class com.github.ddth.queue.impl.universal2.UniversalQueueMessage: Deserializes from a byte[].
fromJson(String) - Method in class com.github.ddth.queue.impl.BaseUniversalQueueMessage

G

getBoundary() - Method in class com.github.ddth.queue.impl.InmemQueue: Gets queue's boundary (max number of elements).
getCfEphemeral() - Method in class com.github.ddth.queue.impl.RocksDbQueue
getCfMetadata() - Method in class com.github.ddth.queue.impl.RocksDbQueue
getCfNameEphemeral() - Method in class com.github.ddth.queue.impl.RocksDbQueue: Name of the ColumnFamily to store ephemeral messages.
getCfNameMetadata() - Method in class com.github.ddth.queue.impl.RocksDbQueue: Name of the ColumnFamily to store metadata.
getCfNameQueue() - Method in class com.github.ddth.queue.impl.RocksDbQueue: Name of the ColumnFamily to store queue messages.
getCfQueue() - Method in class com.github.ddth.queue.impl.RocksDbQueue
getConsumerGroupId() - Method in class com.github.ddth.queue.impl.KafkaQueue: Kafka's group-id to consume messages.
getDefaultConsumerProps() - Method in class com.github.ddth.queue.impl.KafkaQueueFactory
getDefaultDataSource() - Method in class com.github.ddth.queue.impl.JdbcQueueFactory
getDefaultProducerProps() - Method in class com.github.ddth.queue.impl.KafkaQueueFactory
getDefaultProducerType() - Method in class com.github.ddth.queue.impl.KafkaQueueFactory
getDefaultStorageDir() - Method in class com.github.ddth.queue.impl.RocksDbQueueFactory
getEphemeralDisabled() - Method in class com.github.ddth.queue.impl.DisruptorQueue: Is ephemeral storage disabled?
getEphemeralDisabled() - Method in class com.github.ddth.queue.impl.InmemQueue: Is ephemeral storage disabled?
getEphemeralDisabled() - Method in class com.github.ddth.queue.impl.RedisQueue: Is ephemeral storage disabled?
getEphemeralDisabled() - Method in class com.github.ddth.queue.impl.RocksDbQueue: Is ephemeral storage disabled?
getEphemeralDisabled() - Method in class com.github.ddth.queue.impl.universal.UniversalJdbcQueue
getEphemeralDisabled() - Method in class com.github.ddth.queue.impl.universal2.UniversalJdbcQueue
getField(String, Class<T>) - Method in class com.github.ddth.queue.QueueSpec: Gets a field's value.
getField(String) - Method in class com.github.ddth.queue.QueueSpec: Gets a field's value.
getFifo() - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalMySQLQueue: If true, queue message with lower id is ensured to be taken first.
getFifo() - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue: If true, queue message with lower id is ensured to be taken first.
getFifo() - Method in class com.github.ddth.queue.impl.universal.UniversalJdbcQueue: If true, queue message with lower id is ensured to be taken first.
getFifo() - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue
getFifo() - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueue
getFifo() - Method in class com.github.ddth.queue.impl.universal2.UniversalJdbcQueue
getJedisPool() - Method in class com.github.ddth.queue.impl.RedisQueue
getKafkaBootstrapServers() - Method in class com.github.ddth.queue.impl.KafkaQueue: Kafka bootstrap server list (format host1:9092,host2:port2,host3:port3).
getKafkaClient() - Method in class com.github.ddth.queue.impl.KafkaQueue
getKafkaConsumerProperties() - Method in class com.github.ddth.queue.impl.KafkaQueue: Gets Kafka consumer's custom configuration properties.
getKafkaProducerProperties() - Method in class com.github.ddth.queue.impl.KafkaQueue: Gets Kafka producer's custom configuration properties.
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.universal.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.universal.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.universal.UniversalJdbcQueue: 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.universal2.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.universal2.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.universal2.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.DisruptorQueue: 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.InmemQueue: 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 class com.github.ddth.queue.impl.RocksDbQueue: 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
getQueue(QueueSpec) - Method in class com.github.ddth.queue.impl.AbstractQueueFactory: Gets an IQueue instance.
getQueue(QueueSpec) - Method in interface com.github.ddth.queue.IQueueFactory: Gets an IQueue instance.
getReadOptions() - Method in class com.github.ddth.queue.impl.RocksDbQueue
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
getRingSize() - Method in class com.github.ddth.queue.impl.DisruptorQueue: Gets size of the ring buffer.
getRocksDb() - Method in class com.github.ddth.queue.impl.RocksDbQueue
getStorageDir() - Method in class com.github.ddth.queue.impl.RocksDbQueue: RocksDB's storage directory.
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.universal.LessLockingUniversalMySQLQueue
getTableNameEphemeral() - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue
getTableNameEphemeral() - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue
getTableNameEphemeral() - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueue
getTopicName() - Method in class com.github.ddth.queue.impl.KafkaQueue: Name of Kafka topic to store queue messages.
getTransactionIsolationLevel() - Method in class com.github.ddth.queue.impl.JdbcQueue
getWriteOptions() - Method in class com.github.ddth.queue.impl.RocksDbQueue

H

hashCode() - Method in class com.github.ddth.queue.QueueSpec

I

IDGEN - Static variable in class com.github.ddth.queue.utils.QueueUtils
init() - Method in class com.github.ddth.queue.impl.AbstractQueueFactory
init() - Method in class com.github.ddth.queue.impl.DisruptorQueue: Init method.
init() - Method in class com.github.ddth.queue.impl.InmemQueue: Init method.
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.RedisQueue: Init method.
init() - Method in class com.github.ddth.queue.impl.RocksDbQueue: Init method.
init() - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalMySQLQueue
init() - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue
init() - Method in class com.github.ddth.queue.impl.universal.UniversalJdbcQueue
init() - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue
init() - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueue
init() - Method in class com.github.ddth.queue.impl.universal2.UniversalJdbcQueue
initQueue(T, QueueSpec) - Method in class com.github.ddth.queue.impl.AbstractQueueFactory: Initializes a newly created queue instance.
initQueue(T, QueueSpec) - Method in class com.github.ddth.queue.impl.DisruptorQueueFactory: Initializes a newly created queue instance.
initQueue(InmemQueue, QueueSpec) - Method in class com.github.ddth.queue.impl.InmemQueueFactory: Initializes a newly created queue instance.
initQueue(T, QueueSpec) - Method in class com.github.ddth.queue.impl.JdbcQueueFactory: Initializes a newly created queue instance.
initQueue(T, QueueSpec) - Method in class com.github.ddth.queue.impl.KafkaQueueFactory: Initializes a newly created queue instance.
initQueue(T, QueueSpec) - Method in class com.github.ddth.queue.impl.RedisQueueFactory: Initializes a newly created queue instance.
initQueue(T, QueueSpec) - Method in class com.github.ddth.queue.impl.RocksDbQueueFactory: Initializes a newly created queue instance.
InmemQueue - Class in com.github.ddth.queue.impl: In-Memory implementation of IQueue.
InmemQueue() - Constructor for class com.github.ddth.queue.impl.InmemQueue
InmemQueue(int) - Constructor for class com.github.ddth.queue.impl.InmemQueue
InmemQueueFactory<T extends InmemQueue> - Class in com.github.ddth.queue.impl: Factory to create InmemQueue instances.
InmemQueueFactory() - Constructor for class com.github.ddth.queue.impl.InmemQueueFactory
IQueue - Interface in com.github.ddth.queue: APIs to interact with queue.
IQueueFactory - Interface in com.github.ddth.queue: Factory to create IQueue instances.
IQueueMessage - Interface in com.github.ddth.queue: Represents a queue message.
IQueueMessage.EmptyQueueMessage - Class in com.github.ddth.queue: An empty queue message.
isEphemeralDisabled() - Method in class com.github.ddth.queue.impl.DisruptorQueue: Is ephemeral storage disabled?
isEphemeralDisabled() - Method in class com.github.ddth.queue.impl.InmemQueue: Is ephemeral storage disabled?
isEphemeralDisabled() - Method in class com.github.ddth.queue.impl.RedisQueue: Is ephemeral storage disabled?
isEphemeralDisabled() - Method in class com.github.ddth.queue.impl.RocksDbQueue: Is ephemeral storage disabled?
isEphemeralDisabled() - Method in class com.github.ddth.queue.impl.universal.UniversalJdbcQueue
isEphemeralDisabled() - Method in class com.github.ddth.queue.impl.universal2.UniversalJdbcQueue
isFifo() - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalMySQLQueue: If true, queue message with lower id is ensured to be taken first.
isFifo() - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue: If true, queue message with lower id is ensured to be taken first.
isFifo() - Method in class com.github.ddth.queue.impl.universal.UniversalJdbcQueue: If true, queue message with lower id is ensured to be taken first.
isFifo() - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue
isFifo() - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueue
isFifo() - Method in class com.github.ddth.queue.impl.universal2.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
JdbcQueueFactory<T extends JdbcQueue> - Class in com.github.ddth.queue.impl: Factory to create JdbcQueue instances.
JdbcQueueFactory() - Constructor for class com.github.ddth.queue.impl.JdbcQueueFactory

K

KafkaQueue - Class in com.github.ddth.queue.impl: (Experimental) Kafka implementation of IQueue.
KafkaQueue() - Constructor for class com.github.ddth.queue.impl.KafkaQueue
KafkaQueueFactory<T extends KafkaQueue> - Class in com.github.ddth.queue.impl: Factory to create KafkaQueue instances.
KafkaQueueFactory() - Constructor for class com.github.ddth.queue.impl.KafkaQueueFactory

L

LessLockingUniversalMySQLQueue - Class in com.github.ddth.queue.impl.universal: Same as UniversalJdbcQueue, but using a less-locking algorithm - specific for MySQL, and requires only one single db table for both queue and ephemeral storages.
LessLockingUniversalMySQLQueue() - Constructor for class com.github.ddth.queue.impl.universal.LessLockingUniversalMySQLQueue
LessLockingUniversalMySQLQueue - Class in com.github.ddth.queue.impl.universal2: 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.universal2.LessLockingUniversalMySQLQueue
LessLockingUniversalMySQLQueueFactory - Class in com.github.ddth.queue.impl.universal: Factory to create LessLockingUniversalMySQLQueue instances.
LessLockingUniversalMySQLQueueFactory() - Constructor for class com.github.ddth.queue.impl.universal.LessLockingUniversalMySQLQueueFactory
LessLockingUniversalMySQLQueueFactory - Class in com.github.ddth.queue.impl.universal2: Factory to create LessLockingUniversalMySQLQueue instances.
LessLockingUniversalMySQLQueueFactory() - Constructor for class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueueFactory
LessLockingUniversalPgSQLQueue - Class in com.github.ddth.queue.impl.universal: 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.universal.LessLockingUniversalPgSQLQueue
LessLockingUniversalPgSQLQueue - Class in com.github.ddth.queue.impl.universal2: 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.universal2.LessLockingUniversalPgSQLQueue
LessLockingUniversalPgSQLQueueFactory - Class in com.github.ddth.queue.impl.universal: Factory to create LessLockingUniversalPgSQLQueue instances.
LessLockingUniversalPgSQLQueueFactory() - Constructor for class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueueFactory
LessLockingUniversalPgSQLQueueFactory - Class in com.github.ddth.queue.impl.universal2: Factory to create LessLockingUniversalPgSQLQueue instances.
LessLockingUniversalPgSQLQueueFactory() - Constructor for class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueueFactory

M

main(String[]) - Static method in class com.github.ddth.queue.impl.universal.UniversalQueueMessage
main(String[]) - Static method in class com.github.ddth.queue.impl.universal2.UniversalQueueMessage
markEphemeralDisabled(boolean) - Method in class com.github.ddth.queue.impl.universal.UniversalJdbcQueue
markEphemeralDisabled(boolean) - Method in class com.github.ddth.queue.impl.universal2.UniversalJdbcQueue
markFifo(boolean) - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalMySQLQueue: When set to true, queue message with lower id is ensured to be taken first.
markFifo(boolean) - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue: When set to true, queue message with lower id is ensured to be taken first.
markFifo(boolean) - Method in class com.github.ddth.queue.impl.universal.UniversalJdbcQueue: When set to true, queue message with lower id is ensured to be taken first.
markFifo(boolean) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue
markFifo(boolean) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueue
markFifo(boolean) - Method in class com.github.ddth.queue.impl.universal2.UniversalJdbcQueue
moveFromEphemeralToQueueStorage(IQueueMessage) - Method in class com.github.ddth.queue.impl.DisruptorQueue: Moves a message from ephemeral back to queue storage.
moveFromEphemeralToQueueStorage(IQueueMessage) - Method in class com.github.ddth.queue.impl.InmemQueue: Moves a message from ephemeral back to queue storage.
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 class com.github.ddth.queue.impl.RocksDbQueue: 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.impl.universal.UniversalQueueMessage: Creates a new UniversalQueueMessage object.
newInstance() - Static method in class com.github.ddth.queue.impl.universal2.UniversalQueueMessage: Creates a new UniversalQueueMessage object.
NO_BOUNDARY - Static variable in class com.github.ddth.queue.QueueSpec

P

partitionKey() - Method in class com.github.ddth.queue.impl.BaseUniversalQueueMessage: Key used for partitioning messages (some queue implementations, such as Kafka queue, use this).
partitionKey(String) - Method in class com.github.ddth.queue.impl.BaseUniversalQueueMessage: Key used for partitioning messages (some queue implementations, such as Kafka queue, use this).
publish(IQueueMessage, long) - Method in class com.github.ddth.queue.impl.DisruptorQueue: Publishes (commits) the ring's sequence.
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.universal.LessLockingUniversalMySQLQueue: Puts a message to the ephemeral storage.
putToEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue: Puts a message to the ephemeral storage.
putToEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal.UniversalJdbcQueue: Puts a message to the ephemeral storage.
putToEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue: Puts a message to the ephemeral storage.
putToEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueue: Puts a message to the ephemeral storage.
putToEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal2.UniversalJdbcQueue: Puts a message to the ephemeral storage.
putToQueue(IQueueMessage) - Method in class com.github.ddth.queue.impl.BaseUniversalKafkaQueue: Puts a message to Kafka queue, partitioning message by BaseUniversalQueueMessage.partitionKey() (or IQueueMessage.qId() if message is not of type BaseUniversalQueueMessage)).
putToQueue(IQueueMessage) - Method in class com.github.ddth.queue.impl.InmemQueue: Puts a message to the internal queue.
putToQueue(IQueueMessage) - Method in class com.github.ddth.queue.impl.KafkaQueue: Puts a message to Kafka queue, partitioning message by IQueueMessage.qId()
putToQueue(IQueueMessage, boolean) - Method in class com.github.ddth.queue.impl.RocksDbQueue
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.universal.LessLockingUniversalMySQLQueue: Puts a message to tail of the queue storage.
putToQueueStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue: Puts a message to tail of the queue storage.
putToQueueStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal.UniversalJdbcQueue: Puts a message to tail of the queue storage.
putToQueueStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue: Puts a message to tail of the queue storage.
putToQueueStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueue: Puts a message to tail of the queue storage.
putToQueueStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal2.UniversalJdbcQueue: Puts a message to tail of the queue storage.
putToRingBuffer(IQueueMessage) - Method in class com.github.ddth.queue.impl.DisruptorQueue: Puts a message to the ring buffer.

Q

qData() - Method in class com.github.ddth.queue.impl.BaseUniversalQueueMessage: Data/content attached to the queue message.
qData(Object) - Method in class com.github.ddth.queue.impl.BaseUniversalQueueMessage: Attaches data/content to the queue message.
qData() - Method in class com.github.ddth.queue.IQueueMessage.EmptyQueueMessage
qData(Object) - Method in class com.github.ddth.queue.IQueueMessage.EmptyQueueMessage
qData() - Method in interface com.github.ddth.queue.IQueueMessage: Data/content attached to the queue message.
qData(Object) - Method in interface com.github.ddth.queue.IQueueMessage: Attaches data/content to the queue message.
qId() - Method in class com.github.ddth.queue.impl.universal.UniversalQueueMessage: Message's unique id in queue.
qId(Object) - Method in class com.github.ddth.queue.impl.universal.UniversalQueueMessage: Sets message's unique queue id.
qId() - Method in class com.github.ddth.queue.impl.universal2.UniversalQueueMessage: Message's unique id in queue.
qId(Object) - Method in class com.github.ddth.queue.impl.universal2.UniversalQueueMessage: Sets message's unique queue id.
qId() - Method in class com.github.ddth.queue.IQueueMessage.EmptyQueueMessage
qId(Object) - Method in class com.github.ddth.queue.IQueueMessage.EmptyQueueMessage
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.
qIncNumRequeues() - Method in class com.github.ddth.queue.impl.BaseUniversalQueueMessage: Increases message's number of re-queue times by 1.
qIncNumRequeues() - Method in class com.github.ddth.queue.IQueueMessage.EmptyQueueMessage
qIncNumRequeues() - Method in interface com.github.ddth.queue.IQueueMessage: Increases message's number of re-queue times by 1.
qNumRequeues() - Method in class com.github.ddth.queue.impl.BaseUniversalQueueMessage: How many times message has been re-queued?
qNumRequeues(int) - Method in class com.github.ddth.queue.impl.BaseUniversalQueueMessage: Sets message's number of re-queue times.
qNumRequeues() - Method in class com.github.ddth.queue.IQueueMessage.EmptyQueueMessage
qNumRequeues(int) - Method in class com.github.ddth.queue.IQueueMessage.EmptyQueueMessage
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.
qOriginalTimestamp() - Method in class com.github.ddth.queue.impl.BaseUniversalQueueMessage: Message's first-queued timestamp.
qOriginalTimestamp(Date) - Method in class com.github.ddth.queue.impl.BaseUniversalQueueMessage: Sets message's first-queued timestamp.
qOriginalTimestamp() - Method in class com.github.ddth.queue.IQueueMessage.EmptyQueueMessage
qOriginalTimestamp(Date) - Method in class com.github.ddth.queue.IQueueMessage.EmptyQueueMessage
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.
qTimestamp() - Method in class com.github.ddth.queue.impl.BaseUniversalQueueMessage: Message's last-queued timestamp.
qTimestamp(Date) - Method in class com.github.ddth.queue.impl.BaseUniversalQueueMessage: Sets message's last-queued timestamp.
qTimestamp() - Method in class com.github.ddth.queue.IQueueMessage.EmptyQueueMessage
qTimestamp(Date) - Method in class com.github.ddth.queue.IQueueMessage.EmptyQueueMessage
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.
queue(IQueueMessage) - Method in class com.github.ddth.queue.impl.DisruptorQueue: Queues a message.
queue(IQueueMessage) - Method in class com.github.ddth.queue.impl.InmemQueue: Queues a message.
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 class com.github.ddth.queue.impl.RocksDbQueue: 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
QueueException.CannotDeserializeQueueMessage - Exception in com.github.ddth.queue.utils: Thrown to indicate that the queue message can not be deserialized.
QueueException.CannotSerializeQueueMessage - Exception in com.github.ddth.queue.utils: Thrown to indicate that the queue message can not be serialized.
queueInstances - Variable in class com.github.ddth.queue.impl.AbstractQueueFactory
queueSize() - Method in class com.github.ddth.queue.impl.DisruptorQueue: Gets queue's number of items.
queueSize() - Method in class com.github.ddth.queue.impl.InmemQueue: Gets queue's number of items.
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 class com.github.ddth.queue.impl.RocksDbQueue: Gets queue's number of items.
queueSize() - Method in interface com.github.ddth.queue.IQueue: Gets queue's number of items.
QueueSpec - Class in com.github.ddth.queue
QueueSpec() - Constructor for class com.github.ddth.queue.QueueSpec
QueueSpec(boolean) - Constructor for class com.github.ddth.queue.QueueSpec
QueueSpec(int) - Constructor for class com.github.ddth.queue.QueueSpec
QueueSpec(boolean, int) - Constructor for class com.github.ddth.queue.QueueSpec
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.universal.LessLockingUniversalMySQLQueue: Reads a message from the ephemeral storage.
readFromEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue: Reads a message from the ephemeral storage.
readFromEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal.UniversalJdbcQueue: Reads a message from the ephemeral storage.
readFromEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue: Reads a message from the ephemeral storage.
readFromEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueue: Reads a message from the ephemeral storage.
readFromEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal2.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.universal.LessLockingUniversalMySQLQueue: Reads a message from head of queue storage.
readFromQueueStorage(JdbcTemplate) - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue: Reads a message from head of queue storage.
readFromQueueStorage(JdbcTemplate) - Method in class com.github.ddth.queue.impl.universal.UniversalJdbcQueue: Reads a message from head of queue storage.
readFromQueueStorage(JdbcTemplate) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue: Reads a message from head of queue storage.
readFromQueueStorage(JdbcTemplate) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueue: Reads a message from head of queue storage.
readFromQueueStorage(JdbcTemplate) - Method in class com.github.ddth.queue.impl.universal2.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
RedisQueueFactory<T extends RedisQueue> - Class in com.github.ddth.queue.impl: Factory to create RedisQueue instances.
RedisQueueFactory() - Constructor for class com.github.ddth.queue.impl.RedisQueueFactory
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.universal.LessLockingUniversalMySQLQueue: Removes a message from the ephemeral storage.
removeFromEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue: Removes a message from the ephemeral storage.
removeFromEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal.UniversalJdbcQueue: Removes a message from the ephemeral storage.
removeFromEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue: Removes a message from the ephemeral storage.
removeFromEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueue: Removes a message from the ephemeral storage.
removeFromEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal2.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.universal.LessLockingUniversalMySQLQueue: Removes a message from the queue storage.
removeFromQueueStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue: Removes a message from the queue storage.
removeFromQueueStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal.UniversalJdbcQueue: Removes a message from the queue storage.
removeFromQueueStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue: Removes a message from the queue storage.
removeFromQueueStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueue: Removes a message from the queue storage.
removeFromQueueStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.universal2.UniversalJdbcQueue: Removes a message from the queue storage.
requeue(IQueueMessage) - Method in class com.github.ddth.queue.impl.DisruptorQueue: Re-queues a message.
requeue(IQueueMessage) - Method in class com.github.ddth.queue.impl.InmemQueue: Re-queues a message.
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 class com.github.ddth.queue.impl.RocksDbQueue: 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.DisruptorQueue: Silently re-queues a message.
requeueSilent(IQueueMessage) - Method in class com.github.ddth.queue.impl.InmemQueue: Silently 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 class com.github.ddth.queue.impl.RocksDbQueue: Silently re-queues a message.
requeueSilent(IQueueMessage) - Method in interface com.github.ddth.queue.IQueue: Silently re-queues a message.
RocksDbQueue - Class in com.github.ddth.queue.impl: RocksDB implementation of IQueue.
RocksDbQueue() - Constructor for class com.github.ddth.queue.impl.RocksDbQueue
RocksDbQueueFactory<T extends RocksDbQueue> - Class in com.github.ddth.queue.impl: Factory to create RocksDb instances.
RocksDbQueueFactory() - Constructor for class com.github.ddth.queue.impl.RocksDbQueueFactory

S

serialize(IQueueMessage) - Method in class com.github.ddth.queue.impl.BaseUniversalKafkaQueue: Serializes a queue message to store in Kafka.
serialize(IQueueMessage) - Method in class com.github.ddth.queue.impl.BaseUniversalRedisQueue: Serializes a queue message to store in Redis.
serialize(IQueueMessage) - Method in class com.github.ddth.queue.impl.BaseUniversalRocksDbQueue: Serializes a queue message to byte[].
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.RocksDbQueue: Serializes a queue message to byte[].
setBoundary(int) - Method in class com.github.ddth.queue.impl.InmemQueue: Sets queue's boundary (max number of elements).
setCfNameEphemeral(String) - Method in class com.github.ddth.queue.impl.RocksDbQueue: Sets name of the ColumnFamily to store ephemeral messages.
setCfNameMetadata(String) - Method in class com.github.ddth.queue.impl.RocksDbQueue: Sets name of the ColumnFamily to store metadata.
setCfNameQueue(String) - Method in class com.github.ddth.queue.impl.RocksDbQueue: Sets name of the ColumnFamily to store queue messages.
setConsumerGroupId(String) - Method in class com.github.ddth.queue.impl.KafkaQueue
setDefaultConsumerProps(Properties) - Method in class com.github.ddth.queue.impl.KafkaQueueFactory
setDefaultDataSource(DataSource) - Method in class com.github.ddth.queue.impl.JdbcQueueFactory
setDefaultProducerProps(Properties) - Method in class com.github.ddth.queue.impl.KafkaQueueFactory
setDefaultProducerType(KafkaClient.ProducerType) - Method in class com.github.ddth.queue.impl.KafkaQueueFactory
setDefaultStorageDir(String) - Method in class com.github.ddth.queue.impl.RocksDbQueueFactory
setEphemeralDisabled(boolean) - Method in class com.github.ddth.queue.impl.DisruptorQueue: Disables/Enables ephemeral storage.
setEphemeralDisabled(boolean) - Method in class com.github.ddth.queue.impl.InmemQueue: Disables/Enables ephemeral storage.
setEphemeralDisabled(boolean) - Method in class com.github.ddth.queue.impl.RedisQueue: Disables/Enables ephemeral storage.
setEphemeralDisabled(boolean) - Method in class com.github.ddth.queue.impl.RocksDbQueue: Disables/Enables ephemeral storage.
setEphemeralDisabled(boolean) - Method in class com.github.ddth.queue.impl.universal.UniversalJdbcQueue
setEphemeralDisabled(boolean) - Method in class com.github.ddth.queue.impl.universal2.UniversalJdbcQueue
setField(String, Object) - Method in class com.github.ddth.queue.QueueSpec: Sets a field's value.
setFifo(boolean) - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalMySQLQueue: When set to true, queue message with lower id is ensured to be taken first.
setFifo(boolean) - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue: When set to true, queue message with lower id is ensured to be taken first.
setFifo(boolean) - Method in class com.github.ddth.queue.impl.universal.UniversalJdbcQueue: When set to true, queue message with lower id is ensured to be taken first.
setFifo(boolean) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue
setFifo(boolean) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueue
setFifo(boolean) - Method in class com.github.ddth.queue.impl.universal2.UniversalJdbcQueue
setJedisPool(JedisPool) - Method in class com.github.ddth.queue.impl.RedisQueue
setKafkaBootstrapServers(String) - Method in class com.github.ddth.queue.impl.KafkaQueue: Sets Kafka bootstrap server list (format host1:9092,host2:port2,host3:port3).
setKafkaClient(KafkaClient) - Method in class com.github.ddth.queue.impl.KafkaQueue: An external KafkaClient can be used.
setKafkaConsumerProperties(Properties) - Method in class com.github.ddth.queue.impl.KafkaQueue: Sets Kafka consumer's custom configuration properties.
setKafkaProducerProperties(Properties) - Method in class com.github.ddth.queue.impl.KafkaQueue: Sets Kafka producer's custom configuration properties.
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
setRingSize(int) - Method in class com.github.ddth.queue.impl.DisruptorQueue: Sets size of the ring buffer, must be power of 2.
setStorageDir(String) - Method in class com.github.ddth.queue.impl.RocksDbQueue: Sets RocksDB's storage directory.
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
SPEC_FIELD_BOOTSTRAP_SERVERS - Static variable in class com.github.ddth.queue.impl.KafkaQueueFactory
SPEC_FIELD_CF_EPHEMERAL - Static variable in class com.github.ddth.queue.impl.RocksDbQueueFactory
SPEC_FIELD_CF_METADATA - Static variable in class com.github.ddth.queue.impl.RocksDbQueueFactory
SPEC_FIELD_CF_QUEUE - Static variable in class com.github.ddth.queue.impl.RocksDbQueueFactory
SPEC_FIELD_CONSUMER_GROUP_ID - Static variable in class com.github.ddth.queue.impl.KafkaQueueFactory
SPEC_FIELD_CONSUMER_PROPERTIES - Static variable in class com.github.ddth.queue.impl.KafkaQueueFactory
SPEC_FIELD_FIFO - Static variable in class com.github.ddth.queue.impl.universal.LessLockingUniversalMySQLQueueFactory
SPEC_FIELD_FIFO - Static variable in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueueFactory
SPEC_FIELD_FIFO - Static variable in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueueFactory
SPEC_FIELD_FIFO - Static variable in class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueueFactory
SPEC_FIELD_HASH_NAME - Static variable in class com.github.ddth.queue.impl.RedisQueueFactory
SPEC_FIELD_HOST_AND_PORT - Static variable in class com.github.ddth.queue.impl.RedisQueueFactory
SPEC_FIELD_LIST_NAME - Static variable in class com.github.ddth.queue.impl.RedisQueueFactory
SPEC_FIELD_MAX_RETRIES - Static variable in class com.github.ddth.queue.impl.JdbcQueueFactory
SPEC_FIELD_PRODUCER_PROPERTIES - Static variable in class com.github.ddth.queue.impl.KafkaQueueFactory
SPEC_FIELD_PRODUCER_TYPE - Static variable in class com.github.ddth.queue.impl.KafkaQueueFactory
SPEC_FIELD_SORTED_SET_NAME - Static variable in class com.github.ddth.queue.impl.RedisQueueFactory
SPEC_FIELD_STORAGE_DIR - Static variable in class com.github.ddth.queue.impl.RocksDbQueueFactory
SPEC_FIELD_TABLE_NAME - Static variable in class com.github.ddth.queue.impl.JdbcQueueFactory
SPEC_FIELD_TABLE_NAME_EPHEMERAL - Static variable in class com.github.ddth.queue.impl.JdbcQueueFactory
SPEC_FIELD_TOPIC - Static variable in class com.github.ddth.queue.impl.KafkaQueueFactory
SPEC_FIELD_TRANSACTION_ISOLATION_LEVEL - Static variable in class com.github.ddth.queue.impl.JdbcQueueFactory
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.BaseUniversalDisruptorQueue: Takes a message out of queue.
take() - Method in class com.github.ddth.queue.impl.BaseUniversalInmemQueue: Takes a message out of queue.
take() - Method in class com.github.ddth.queue.impl.BaseUniversalKafkaQueue: Takes a message out of queue.
take() - Method in class com.github.ddth.queue.impl.BaseUniversalRedisQueue: Takes a message out of queue.
take() - Method in class com.github.ddth.queue.impl.BaseUniversalRocksDbQueue: Takes a message out of queue.
take() - Method in class com.github.ddth.queue.impl.DisruptorQueue: Takes a message out of queue.
take() - Method in class com.github.ddth.queue.impl.InmemQueue: Takes a message out of queue.
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.RedisQueue: Takes a message out of queue.
take() - Method in class com.github.ddth.queue.impl.RocksDbQueue: Takes a message out of queue.
take() - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalMySQLQueue: Takes a message out of queue.
take() - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue: Takes a message out of queue.
take() - Method in class com.github.ddth.queue.impl.universal.UniversalJdbcQueue: Takes a message out of queue.
take() - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue: Takes a message out of queue.
take() - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueue: Takes a message out of queue.
take() - Method in class com.github.ddth.queue.impl.universal2.UniversalJdbcQueue: Takes a message out of queue.
take() - Method in interface com.github.ddth.queue.IQueue: Takes a message out of queue.
takeFromQueue() - Method in class com.github.ddth.queue.impl.InmemQueue: Takes a message from the internal queue.
takeFromQueue() - Method in class com.github.ddth.queue.impl.KafkaQueue: Takes a message from Kafka queue.
takeFromRingBuffer() - Method in class com.github.ddth.queue.impl.DisruptorQueue: Takes a message from the ring buffer.
toBytes() - Method in class com.github.ddth.queue.impl.BaseUniversalQueueMessage: Serializes to byte[].
toString() - Method in class com.github.ddth.queue.QueueSpec

U

UniversalDisruptorQueue - Class in com.github.ddth.queue.impl.universal: Universal LMAX Disruptor implementation of IQueue.
UniversalDisruptorQueue() - Constructor for class com.github.ddth.queue.impl.universal.UniversalDisruptorQueue
UniversalDisruptorQueue(int) - Constructor for class com.github.ddth.queue.impl.universal.UniversalDisruptorQueue
UniversalDisruptorQueue - Class in com.github.ddth.queue.impl.universal2: Universal LMAX Disruptor implementation of IQueue.
UniversalDisruptorQueue() - Constructor for class com.github.ddth.queue.impl.universal2.UniversalDisruptorQueue
UniversalDisruptorQueue(int) - Constructor for class com.github.ddth.queue.impl.universal2.UniversalDisruptorQueue
UniversalDisruptorQueueFactory - Class in com.github.ddth.queue.impl.universal: Factory to create UniversalDisruptorQueue instances.
UniversalDisruptorQueueFactory() - Constructor for class com.github.ddth.queue.impl.universal.UniversalDisruptorQueueFactory
UniversalDisruptorQueueFactory - Class in com.github.ddth.queue.impl.universal2: Factory to create UniversalDisruptorQueue instances.
UniversalDisruptorQueueFactory() - Constructor for class com.github.ddth.queue.impl.universal2.UniversalDisruptorQueueFactory
UniversalInmemQueue - Class in com.github.ddth.queue.impl.universal: Universal in-memory implementation of IQueue.
UniversalInmemQueue() - Constructor for class com.github.ddth.queue.impl.universal.UniversalInmemQueue
UniversalInmemQueue(int) - Constructor for class com.github.ddth.queue.impl.universal.UniversalInmemQueue
UniversalInmemQueue - Class in com.github.ddth.queue.impl.universal2: Universal in-memory implementation of IQueue.
UniversalInmemQueue() - Constructor for class com.github.ddth.queue.impl.universal2.UniversalInmemQueue
UniversalInmemQueue(int) - Constructor for class com.github.ddth.queue.impl.universal2.UniversalInmemQueue
UniversalInmemQueueFactory - Class in com.github.ddth.queue.impl.universal: Factory to create UniversalInmemQueue instances.
UniversalInmemQueueFactory() - Constructor for class com.github.ddth.queue.impl.universal.UniversalInmemQueueFactory
UniversalInmemQueueFactory - Class in com.github.ddth.queue.impl.universal2: Factory to create UniversalInmemQueue instances.
UniversalInmemQueueFactory() - Constructor for class com.github.ddth.queue.impl.universal2.UniversalInmemQueueFactory
UniversalJdbcQueue - Class in com.github.ddth.queue.impl.universal: Universal JDBC implementation of IQueue.
UniversalJdbcQueue() - Constructor for class com.github.ddth.queue.impl.universal.UniversalJdbcQueue
UniversalJdbcQueue - Class in com.github.ddth.queue.impl.universal2: Universal JDBC implementation of IQueue.
UniversalJdbcQueue() - Constructor for class com.github.ddth.queue.impl.universal2.UniversalJdbcQueue
UniversalJdbcQueueFactory - Class in com.github.ddth.queue.impl.universal: Factory to create UniversalJdbcQueue instances.
UniversalJdbcQueueFactory() - Constructor for class com.github.ddth.queue.impl.universal.UniversalJdbcQueueFactory
UniversalJdbcQueueFactory - Class in com.github.ddth.queue.impl.universal2: Factory to create UniversalJdbcQueue instances.
UniversalJdbcQueueFactory() - Constructor for class com.github.ddth.queue.impl.universal2.UniversalJdbcQueueFactory
UniversalKafkaQueue - Class in com.github.ddth.queue.impl.universal: (Experimental) Universal Kafka implementation of IQueue.
UniversalKafkaQueue() - Constructor for class com.github.ddth.queue.impl.universal.UniversalKafkaQueue
UniversalKafkaQueue - Class in com.github.ddth.queue.impl.universal2: (Experimental) Universal Kafka implementation of IQueue.
UniversalKafkaQueue() - Constructor for class com.github.ddth.queue.impl.universal2.UniversalKafkaQueue
UniversalKafkaQueueFactory - Class in com.github.ddth.queue.impl.universal: Factory to create UniversalKafkaQueue instances.
UniversalKafkaQueueFactory() - Constructor for class com.github.ddth.queue.impl.universal.UniversalKafkaQueueFactory
UniversalKafkaQueueFactory - Class in com.github.ddth.queue.impl.universal2: Factory to create UniversalKafkaQueue instances.
UniversalKafkaQueueFactory() - Constructor for class com.github.ddth.queue.impl.universal2.UniversalKafkaQueueFactory
UniversalQueueMessage - Class in com.github.ddth.queue.impl.universal: Extended from BaseUniversalQueueMessage where queue_id is a long.
UniversalQueueMessage() - Constructor for class com.github.ddth.queue.impl.universal.UniversalQueueMessage
UniversalQueueMessage - Class in com.github.ddth.queue.impl.universal2: Extended from BaseUniversalQueueMessage where queue_id is a String.
UniversalQueueMessage() - Constructor for class com.github.ddth.queue.impl.universal2.UniversalQueueMessage
UniversalRedisQueue - Class in com.github.ddth.queue.impl.universal: Universal Redis implementation of IQueue.
UniversalRedisQueue() - Constructor for class com.github.ddth.queue.impl.universal.UniversalRedisQueue
UniversalRedisQueue - Class in com.github.ddth.queue.impl.universal2: Universal Redis implementation of IQueue.
UniversalRedisQueue() - Constructor for class com.github.ddth.queue.impl.universal2.UniversalRedisQueue
UniversalRedisQueueFactory - Class in com.github.ddth.queue.impl.universal: Factory to create UniversalRedisQueue instances.
UniversalRedisQueueFactory() - Constructor for class com.github.ddth.queue.impl.universal.UniversalRedisQueueFactory
UniversalRedisQueueFactory - Class in com.github.ddth.queue.impl.universal2: Factory to create UniversalRedisQueue instances.
UniversalRedisQueueFactory() - Constructor for class com.github.ddth.queue.impl.universal2.UniversalRedisQueueFactory
UniversalRocksDbQueue - Class in com.github.ddth.queue.impl.universal: Universal RocskDB implementation of IQueue.
UniversalRocksDbQueue() - Constructor for class com.github.ddth.queue.impl.universal.UniversalRocksDbQueue
UniversalRocksDbQueue - Class in com.github.ddth.queue.impl.universal2: Universal RocskDB implementation of IQueue.
UniversalRocksDbQueue() - Constructor for class com.github.ddth.queue.impl.universal2.UniversalRocksDbQueue
UniversalRocksDbQueueFactory - Class in com.github.ddth.queue.impl.universal: Factory to create UniversalRocksDbQueue instances.
UniversalRocksDbQueueFactory() - Constructor for class com.github.ddth.queue.impl.universal.UniversalRocksDbQueueFactory
UniversalRocksDbQueueFactory - Class in com.github.ddth.queue.impl.universal2: Factory to create UniversalRocksDbQueue instances.
UniversalRocksDbQueueFactory() - Constructor for class com.github.ddth.queue.impl.universal2.UniversalRocksDbQueueFactory
updatePublishedSequence() - Method in class com.github.ddth.queue.impl.DisruptorQueue: Updates the published sequence number after a message has been successfully taken from queue.
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.universal.LessLockingUniversalMySQLQueue: Performs "finish" action, retry if deadlock.
_finishWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue: Performs "finish" action, retry if deadlock.
_finishWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue: Performs "finish" action, retry if deadlock.
_finishWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.universal2.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.universal.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.universal.LessLockingUniversalPgSQLQueue: 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.universal2.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.universal2.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.universal.LessLockingUniversalMySQLQueue: Queues a message, retry if deadlock.
_queueWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue: Queues a message, retry if deadlock.
_queueWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue: Queues a message, retry if deadlock.
_queueWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.universal2.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.universal.LessLockingUniversalMySQLQueue: Re-queues a message silently, retry if deadlock.
_requeueSilentWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue: Re-queues a message silently, retry if deadlock.
_requeueSilentWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue: Re-queues a message silently, retry if deadlock.
_requeueSilentWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.universal2.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.universal.LessLockingUniversalMySQLQueue: Re-queues a message, retry if deadlock.
_requeueWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue: Re-queues a message, retry if deadlock.
_requeueWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue: Re-queues a message, retry if deadlock.
_requeueWithRetries(Connection, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.universal2.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.universal.LessLockingUniversalMySQLQueue: Takes a message from queue, retry if deadlock.
_takeWithRetries(Connection, int, int) - Method in class com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueue: Takes a message from queue, retry if deadlock.
_takeWithRetries(Connection, int, int) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalMySQLQueue: Takes a message from queue, retry if deadlock.
_takeWithRetries(Connection, int, int) - Method in class com.github.ddth.queue.impl.universal2.LessLockingUniversalPgSQLQueue: Takes a message from queue, retry if deadlock.

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