com.github.ddth.queue.impl

Class RedisQueueFactory<T extends RedisQueue>

java.lang.Object

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

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

All Implemented Interfaces:

IQueueFactory

Direct Known Subclasses:

UniversalRedisQueueFactory, UniversalRedisQueueFactory

public abstract class RedisQueueFactory<T extends RedisQueue>
extends AbstractQueueFactory<T>

Factory to create RedisQueue instances.

Since:

0.4.1

Author:

Thanh Ba Nguyen

Field Summary

Fields

Modifier and Type	Field and Description
static String	SPEC_FIELD_HASH_NAME
static String	SPEC_FIELD_HOST_AND_PORT
static String	SPEC_FIELD_LIST_NAME
static String	SPEC_FIELD_SORTED_SET_NAME

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

queueInstances

Constructor Summary

Constructors

Constructor and Description
RedisQueueFactory()

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

Field Detail

SPEC_FIELD_HASH_NAME

public static final String SPEC_FIELD_HASH_NAME

See Also:

Constant Field Values

SPEC_FIELD_LIST_NAME

public static final String SPEC_FIELD_LIST_NAME

See Also:

Constant Field Values

SPEC_FIELD_SORTED_SET_NAME

public static final String SPEC_FIELD_SORTED_SET_NAME

See Also:

Constant Field Values

SPEC_FIELD_HOST_AND_PORT

public static final String SPEC_FIELD_HOST_AND_PORT

See Also:

Constant Field Values

Constructor Detail

RedisQueueFactory

public RedisQueueFactory()

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 RedisQueue>

disposeQueue

protected boolean disposeQueue(T queue)

Specified by:

disposeQueue in class AbstractQueueFactory<T extends RedisQueue>