com.github.ddth.queue.impl

Class JdbcQueueFactory<T extends JdbcQueue>

java.lang.Object

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

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

All Implemented Interfaces:

IQueueFactory

Direct Known Subclasses:

LessLockingUniversalMySQLQueueFactory, LessLockingUniversalMySQLQueueFactory, LessLockingUniversalPgSQLQueueFactory, LessLockingUniversalPgSQLQueueFactory, UniversalJdbcQueueFactory, UniversalJdbcQueueFactory

public abstract class JdbcQueueFactory<T extends JdbcQueue>
extends AbstractQueueFactory<T>

Factory to create JdbcQueue instances.

Since:

0.4.1

Author:

Thanh Ba Nguyen

Field Summary

Fields

Modifier and Type	Field and Description
static String	SPEC_FIELD_MAX_RETRIES
static String	SPEC_FIELD_TABLE_NAME
static String	SPEC_FIELD_TABLE_NAME_EPHEMERAL
static String	SPEC_FIELD_TRANSACTION_ISOLATION_LEVEL

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

queueInstances

Constructor Summary

Constructors

Constructor and Description
JdbcQueueFactory()

Method Summary

Modifier and Type	Method and Description
protected boolean	disposeQueue(T queue)
DataSource	getDefaultDataSource()
protected void	initQueue(T queue, QueueSpec spec) Initializes a newly created queue instance.
JdbcQueueFactory<T>	setDefaultDataSource(DataSource dataSource)

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_TABLE_NAME

public static final String SPEC_FIELD_TABLE_NAME

See Also:

Constant Field Values

SPEC_FIELD_TABLE_NAME_EPHEMERAL

public static final String SPEC_FIELD_TABLE_NAME_EPHEMERAL

See Also:

Constant Field Values

SPEC_FIELD_MAX_RETRIES

public static final String SPEC_FIELD_MAX_RETRIES

See Also:

Constant Field Values

SPEC_FIELD_TRANSACTION_ISOLATION_LEVEL

public static final String SPEC_FIELD_TRANSACTION_ISOLATION_LEVEL

See Also:

Constant Field Values

Constructor Detail

JdbcQueueFactory

public JdbcQueueFactory()

Method Detail

getDefaultDataSource

public DataSource getDefaultDataSource()

setDefaultDataSource

public JdbcQueueFactory<T> setDefaultDataSource(DataSource dataSource)

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

disposeQueue

protected boolean disposeQueue(T queue)

Specified by:

disposeQueue in class AbstractQueueFactory<T extends JdbcQueue>