com.github.ddth.queue.impl

Class BaseUniversalDisruptorQueue<T extends BaseUniversalQueueMessage>

java.lang.Object

com.github.ddth.queue.impl.DisruptorQueue

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

Type Parameters:

T -

All Implemented Interfaces:

IQueue, Closeable, AutoCloseable

Direct Known Subclasses:

UniversalDisruptorQueue, UniversalDisruptorQueue

public class BaseUniversalDisruptorQueue<T extends BaseUniversalQueueMessage>
extends DisruptorQueue

Base class for universal LMAX Disruptor queue implementations.

Since:

0.4.0

Author:

Thanh Nguyen

Constructor Summary

Constructors

Constructor and Description
BaseUniversalDisruptorQueue()
BaseUniversalDisruptorQueue(int ringSize)

Method Summary

Modifier and Type	Method and Description
T	take() Takes a message out of queue.

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

BaseUniversalDisruptorQueue

public BaseUniversalDisruptorQueue()

BaseUniversalDisruptorQueue

public BaseUniversalDisruptorQueue(int ringSize)

Method Detail

take

public T take()

Takes a message out of queue.

Implementation flow:

• Read message from head of queue storage.
• Write message to ephemeral storage.
• Remove message from queue storage.

Note: ephemeral storage implementation is optional, depends on implementation.

Specified by:

take in interface IQueue

Overrides:

take in class DisruptorQueue

Returns: