Package com.github.ddth.queue.impl

Class Summary

Class	Description
AbstractQueueFactory<T extends IQueue>
BaseUniversalDisruptorQueue<T extends BaseUniversalQueueMessage>	Base class for universal LMAX Disruptor queue implementations.
BaseUniversalInmemQueue<T extends BaseUniversalQueueMessage>	Base class for universal in-memory queue implementations.
BaseUniversalKafkaQueue<T extends BaseUniversalQueueMessage>	Base class for universal Kafka queue implementations.
BaseUniversalQueueMessage	Base class for universal queue messages.
BaseUniversalRedisQueue<T extends BaseUniversalQueueMessage>	Base class for universal Redis queue implementations.
BaseUniversalRocksDbQueue<T extends BaseUniversalQueueMessage>	Base class for universal RocksDB queue implementations.
DisruptorQueue	In-Memory implementation of IQueue using LMAX Disruptor library.
DisruptorQueueFactory<T extends DisruptorQueue>	Factory to create DisruptorQueue instances.
InmemQueue	In-Memory implementation of IQueue.
InmemQueueFactory<T extends InmemQueue>	Factory to create InmemQueue instances.
JdbcQueue	Abstract JDBC implementation of IQueue.
JdbcQueueFactory<T extends JdbcQueue>	Factory to create JdbcQueue instances.
KafkaQueue	(Experimental) Kafka implementation of IQueue.
KafkaQueueFactory<T extends KafkaQueue>	Factory to create KafkaQueue instances.
RedisQueue	Redis implementation of IQueue.
RedisQueueFactory<T extends RedisQueue>	Factory to create RedisQueue instances.
RocksDbQueue	RocksDB implementation of IQueue.
RocksDbQueueFactory<T extends RocksDbQueue>	Factory to create RocksDb instances.