| Package | Description |
|---|---|
| com.github.ddth.queue | |
| com.github.ddth.queue.impl | |
| com.github.ddth.queue.impl.universal | |
| com.github.ddth.queue.impl.universal2 |
| Modifier and Type | Method and Description |
|---|---|
QueueSpec |
QueueSpec.setField(String fieldName,
Object value)
Sets a field's value.
|
| Modifier and Type | Method and Description |
|---|---|
IQueue |
IQueueFactory.getQueue(QueueSpec spec)
Gets an
IQueue instance. |
| Modifier and Type | Field and Description |
|---|---|
protected ConcurrentMap<QueueSpec,T> |
AbstractQueueFactory.queueInstances |
| Modifier and Type | Method and Description |
|---|---|
protected T |
AbstractQueueFactory.createAndInitQueue(QueueSpec spec)
Creates & Initializes a new queue instance.
|
protected abstract T |
AbstractQueueFactory.createQueueInstance(QueueSpec spec)
Creates a new queue instance.
|
protected boolean |
AbstractQueueFactory.disposeQueue(QueueSpec id,
T queue) |
T |
AbstractQueueFactory.getQueue(QueueSpec spec)
Gets an
IQueue instance. |
protected void |
InmemQueueFactory.initQueue(InmemQueue queue,
QueueSpec spec)
Initializes a newly created queue instance.
|
protected void |
RocksDbQueueFactory.initQueue(T queue,
QueueSpec spec)
Initializes a newly created queue instance.
|
protected void |
RedisQueueFactory.initQueue(T queue,
QueueSpec spec)
Initializes a newly created queue instance.
|
protected void |
KafkaQueueFactory.initQueue(T queue,
QueueSpec spec)
Initializes a newly created queue instance.
|
protected void |
JdbcQueueFactory.initQueue(T queue,
QueueSpec spec)
Initializes a newly created queue instance.
|
protected void |
DisruptorQueueFactory.initQueue(T queue,
QueueSpec spec)
Initializes a newly created queue instance.
|
protected void |
AbstractQueueFactory.initQueue(T queue,
QueueSpec spec)
Initializes a newly created queue instance.
|
| Modifier and Type | Method and Description |
|---|---|
protected UniversalRocksDbQueue |
UniversalRocksDbQueueFactory.createQueueInstance(QueueSpec spec)
Creates a new queue instance.
|
protected UniversalRedisQueue |
UniversalRedisQueueFactory.createQueueInstance(QueueSpec spec)
Creates a new queue instance.
|
protected UniversalKafkaQueue |
UniversalKafkaQueueFactory.createQueueInstance(QueueSpec spec)
Creates a new queue instance.
|
protected UniversalJdbcQueue |
UniversalJdbcQueueFactory.createQueueInstance(QueueSpec spec)
Creates a new queue instance.
|
protected UniversalInmemQueue |
UniversalInmemQueueFactory.createQueueInstance(QueueSpec spec)
Creates a new queue instance.
|
protected UniversalDisruptorQueue |
UniversalDisruptorQueueFactory.createQueueInstance(QueueSpec spec)
Creates a new queue instance.
|
protected LessLockingUniversalPgSQLQueue |
LessLockingUniversalPgSQLQueueFactory.createQueueInstance(QueueSpec spec)
Creates a new queue instance.
|
protected LessLockingUniversalMySQLQueue |
LessLockingUniversalMySQLQueueFactory.createQueueInstance(QueueSpec spec)
Creates a new queue instance.
|
| Modifier and Type | Method and Description |
|---|---|
protected UniversalRocksDbQueue |
UniversalRocksDbQueueFactory.createQueueInstance(QueueSpec spec)
Creates a new queue instance.
|
protected UniversalRedisQueue |
UniversalRedisQueueFactory.createQueueInstance(QueueSpec spec)
Creates a new queue instance.
|
protected UniversalKafkaQueue |
UniversalKafkaQueueFactory.createQueueInstance(QueueSpec spec)
Creates a new queue instance.
|
protected UniversalJdbcQueue |
UniversalJdbcQueueFactory.createQueueInstance(QueueSpec spec)
Creates a new queue instance.
|
protected UniversalInmemQueue |
UniversalInmemQueueFactory.createQueueInstance(QueueSpec spec)
Creates a new queue instance.
|
protected UniversalDisruptorQueue |
UniversalDisruptorQueueFactory.createQueueInstance(QueueSpec spec)
Creates a new queue instance.
|
protected LessLockingUniversalPgSQLQueue |
LessLockingUniversalPgSQLQueueFactory.createQueueInstance(QueueSpec spec)
Creates a new queue instance.
|
protected LessLockingUniversalMySQLQueue |
LessLockingUniversalMySQLQueueFactory.createQueueInstance(QueueSpec spec)
Creates a new queue instance.
|
Copyright © 2016 DDTH. All rights reserved.