| Package | Description |
|---|---|
| com.github.ddth.queue | |
| com.github.ddth.queue.impl | |
| com.github.ddth.queue.impl.universal |
| Modifier and Type | Method and Description |
|---|---|
IQueue |
IQueueFactory.getQueue(QueueSpec spec)
Gets an
IQueue instance. |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractQueueFactory<T extends IQueue> |
| Modifier and Type | Class and Description |
|---|---|
class |
BaseUniversalDisruptorQueue<T extends BaseUniversalQueueMessage>
Base class for universal LMAX Disruptor queue implementations.
|
class |
BaseUniversalInmemQueue<T extends BaseUniversalQueueMessage>
Base class for universal in-memory queue implementations.
|
class |
BaseUniversalKafkaQueue<T extends BaseUniversalQueueMessage>
Base class for universal Kafka queue implementations.
|
class |
BaseUniversalRedisQueue<T extends BaseUniversalQueueMessage>
Base class for universal Redis queue implementations.
|
class |
BaseUniversalRocksDbQueue<T extends BaseUniversalQueueMessage>
Base class for universal RocksDB queue implementations.
|
class |
DisruptorQueue
In-Memory implementation of
IQueue using LMAX Disruptor library. |
class |
InmemQueue
In-Memory implementation of
IQueue. |
class |
JdbcQueue
Abstract JDBC implementation of
IQueue. |
class |
KafkaQueue
(Experimental) Kafka implementation of
IQueue. |
class |
RedisQueue
Redis implementation of
IQueue. |
class |
RocksDbQueue
RocksDB implementation of
IQueue. |
| Modifier and Type | Class and Description |
|---|---|
class |
LessLockingUniversalMySQLQueue
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. |
class |
LessLockingUniversalPgSQLQueue
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. |
class |
UniversalDisruptorQueue
Universal LMAX Disruptor implementation of
IQueue. |
class |
UniversalInmemQueue
Universal in-memory implementation of
IQueue. |
class |
UniversalJdbcQueue
Universal JDBC implementation of
IQueue. |
class |
UniversalKafkaQueue
(Experimental) Universal Kafka implementation of
IQueue. |
class |
UniversalRedisQueue
Universal Redis implementation of
IQueue. |
class |
UniversalRocksDbQueue
Universal RocskDB implementation of
IQueue. |
Copyright © 2016 DDTH. All rights reserved.