com.github.ddth.queue.impl.universal

Class UniversalDisruptorQueue

java.lang.Object

com.github.ddth.queue.impl.DisruptorQueue

com.github.ddth.queue.impl.BaseUniversalDisruptorQueue<UniversalQueueMessage>

com.github.ddth.queue.impl.universal.UniversalDisruptorQueue

All Implemented Interfaces:

IQueue, Closeable, AutoCloseable

public class UniversalDisruptorQueue
extends BaseUniversalDisruptorQueue<UniversalQueueMessage>

Universal LMAX Disruptor implementation of IQueue.

Queue and Take UniversalQueueMessages.

Since:

0.4.0

Author:

Thanh Ba Nguyen

Constructor Summary

Constructors

Constructor and Description
UniversalDisruptorQueue()
UniversalDisruptorQueue(int ringSize)

Method Summary

Methods inherited from class com.github.ddth.queue.impl.BaseUniversalDisruptorQueue

take

Methods inherited from class com.github.ddth.queue.impl.DisruptorQueue

close, destroy, ephemeralSize, finish, getEphemeralDisabled, getOrphanMessages, getRingSize, init, isEphemeralDisabled, moveFromEphemeralToQueueStorage, publish, putToRingBuffer, queue, queueSize, requeue, requeueSilent, setEphemeralDisabled, setRingSize, takeFromRingBuffer, updatePublishedSequence

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

UniversalDisruptorQueue

public UniversalDisruptorQueue()

UniversalDisruptorQueue

public UniversalDisruptorQueue(int ringSize)