com.github.ddth.queue.impl

Class DisruptorQueueFactory<T extends DisruptorQueue>

java.lang.Object

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

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

All Implemented Interfaces:

IQueueFactory

Direct Known Subclasses:

UniversalDisruptorQueueFactory, UniversalDisruptorQueueFactory

public abstract class DisruptorQueueFactory<T extends DisruptorQueue>
extends AbstractQueueFactory<T>

Factory to create DisruptorQueue instances.

Since:

0.4.1

Author:

Thanh Ba Nguyen

Field Summary

Fields inherited from class com.github.ddth.queue.impl.AbstractQueueFactory

queueInstances

Constructor Summary

Constructors

Constructor and Description
DisruptorQueueFactory()

Method Summary

Modifier and Type	Method and Description
protected boolean	disposeQueue(T queue)
protected void	initQueue(T queue, QueueSpec spec) Initializes a newly created queue instance.

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

createAndInitQueue, createQueueInstance, destroy, disposeQueue, getQueue, init

Methods inherited from class java.lang.Object

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

Constructor Detail

DisruptorQueueFactory

public DisruptorQueueFactory()

Method Detail

initQueue

protected void initQueue(T queue,
                         QueueSpec spec)

Initializes a newly created queue instance.

Called by AbstractQueueFactory.createAndInitQueue(QueueSpec). Sub-class may override this method to implement its own business logic.

Overrides:

initQueue in class AbstractQueueFactory<T extends DisruptorQueue>

disposeQueue

protected boolean disposeQueue(T queue)

Specified by:

disposeQueue in class AbstractQueueFactory<T extends DisruptorQueue>