com.github.ddth.queue.impl.universal

Class UniversalInmemQueue

java.lang.Object

com.github.ddth.queue.impl.InmemQueue

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

com.github.ddth.queue.impl.universal.UniversalInmemQueue

All Implemented Interfaces:

IQueue, Closeable, AutoCloseable

public class UniversalInmemQueue
extends BaseUniversalInmemQueue<UniversalQueueMessage>

Universal in-memory implementation of IQueue.

Queue and Take UniversalQueueMessages.

Since:

0.4.0

Author:

Thanh Ba Nguyen

Constructor Summary

Constructors

Constructor and Description
UniversalInmemQueue()
UniversalInmemQueue(int boundary)

Method Summary

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

take

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

close, createQueue, destroy, ephemeralSize, finish, getBoundary, getEphemeralDisabled, getOrphanMessages, init, isEphemeralDisabled, moveFromEphemeralToQueueStorage, putToQueue, queue, queueSize, requeue, requeueSilent, setBoundary, setEphemeralDisabled, takeFromQueue

Methods inherited from class java.lang.Object

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

Constructor Detail

UniversalInmemQueue

public UniversalInmemQueue()

UniversalInmemQueue

public UniversalInmemQueue(int boundary)