com.github.ddth.queue.impl

Class AbstractQueueFactory<T extends IQueue>

java.lang.Object

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

All Implemented Interfaces:

IQueueFactory

Direct Known Subclasses:

DisruptorQueueFactory, InmemQueueFactory, JdbcQueueFactory, KafkaQueueFactory, RedisQueueFactory, RocksDbQueueFactory

public abstract class AbstractQueueFactory<T extends IQueue>
extends Object
implements IQueueFactory

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentMap<QueueSpec,T>	queueInstances

Constructor Summary

Constructors

Constructor and Description
AbstractQueueFactory()

Method Summary

Modifier and Type	Method and Description
protected T	createAndInitQueue(QueueSpec spec) Creates & Initializes a new queue instance.
protected abstract T	createQueueInstance(QueueSpec spec) Creates a new queue instance.
void	destroy()
protected boolean	disposeQueue(QueueSpec id, T queue)
protected abstract boolean	disposeQueue(T queue)
T	getQueue(QueueSpec spec) Gets an IQueue instance.
AbstractQueueFactory<T>	init()
protected void	initQueue(T queue, QueueSpec spec) Initializes a newly created queue instance.

Methods inherited from class java.lang.Object

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

Field Detail

queueInstances

protected ConcurrentMap<QueueSpec,T extends IQueue> queueInstances

Constructor Detail

AbstractQueueFactory

public AbstractQueueFactory()

Method Detail

init

public AbstractQueueFactory<T> init()

destroy

public void destroy()

createQueueInstance

protected abstract T createQueueInstance(QueueSpec spec)

Creates a new queue instance.

Called by createAndInitQueue(QueueSpec). Sub-class is to implement this method.

Parameters:

spec -

Returns:

initQueue

protected void initQueue(T queue,
                         QueueSpec spec)

Initializes a newly created queue instance.

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

Parameters:

queue -

spec -

createAndInitQueue

protected T createAndInitQueue(QueueSpec spec)

Creates & Initializes a new queue instance.

Parameters:

spec -

Returns:

disposeQueue

protected abstract boolean disposeQueue(T queue)

disposeQueue

protected boolean disposeQueue(QueueSpec id,
                               T queue)

getQueue

public T getQueue(QueueSpec spec)

Gets an IQueue instance.

Specified by:

getQueue in interface IQueueFactory

Parameters:

spec - concrete class defines format of spec.

Returns: