| Package | Description |
|---|---|
| com.github.ddth.queue.impl | |
| com.github.ddth.queue.impl.universal |
| Modifier and Type | Class and Description |
|---|---|
class |
DisruptorQueueFactory<T extends DisruptorQueue>
Factory to create
DisruptorQueue instances. |
| Modifier and Type | Class and Description |
|---|---|
class |
BaseUniversalDisruptorQueue<T extends BaseUniversalQueueMessage>
Base class for universal LMAX Disruptor queue implementations.
|
| Modifier and Type | Method and Description |
|---|---|
DisruptorQueue |
DisruptorQueue.init()
Init method.
|
DisruptorQueue |
DisruptorQueue.setEphemeralDisabled(boolean ephemeralDisabled)
Disables/Enables ephemeral storage.
|
DisruptorQueue |
DisruptorQueue.setRingSize(int ringSize)
Sets size of the ring buffer, must be power of 2.
|
| Modifier and Type | Class and Description |
|---|---|
class |
UniversalDisruptorQueue
Universal LMAX Disruptor implementation of
IQueue. |
Copyright © 2016 DDTH. All rights reserved.