| Package | Description |
|---|---|
| com.github.ddth.queue.impl | |
| com.github.ddth.queue.impl.universal |
| Modifier and Type | Class and Description |
|---|---|
class |
InmemQueueFactory<T extends InmemQueue>
Factory to create
InmemQueue instances. |
| Modifier and Type | Class and Description |
|---|---|
class |
BaseUniversalInmemQueue<T extends BaseUniversalQueueMessage>
Base class for universal in-memory queue implementations.
|
| Modifier and Type | Method and Description |
|---|---|
InmemQueue |
InmemQueue.init()
Init method.
|
InmemQueue |
InmemQueue.setBoundary(int boundary)
Sets queue's boundary (max number of elements).
|
InmemQueue |
InmemQueue.setEphemeralDisabled(boolean ephemeralDisabled)
Disables/Enables ephemeral storage.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
InmemQueueFactory.initQueue(InmemQueue queue,
QueueSpec spec)
Initializes a newly created queue instance.
|
| Modifier and Type | Class and Description |
|---|---|
class |
UniversalInmemQueue
Universal in-memory implementation of
IQueue. |
Copyright © 2016 DDTH. All rights reserved.