com.github.ddth.queue.impl.universal

Class LessLockingUniversalPgSQLQueueFactory

java.lang.Object

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

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

com.github.ddth.queue.impl.universal.LessLockingUniversalPgSQLQueueFactory

All Implemented Interfaces:

IQueueFactory

public class LessLockingUniversalPgSQLQueueFactory
extends JdbcQueueFactory<LessLockingUniversalPgSQLQueue>

Factory to create LessLockingUniversalPgSQLQueue instances.

Since:

0.4.1

Author:

Thanh Ba Nguyen

Field Summary

Fields

Modifier and Type	Field and Description
static String	SPEC_FIELD_FIFO

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

SPEC_FIELD_MAX_RETRIES, SPEC_FIELD_TABLE_NAME, SPEC_FIELD_TABLE_NAME_EPHEMERAL, SPEC_FIELD_TRANSACTION_ISOLATION_LEVEL

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

queueInstances

Constructor Summary

Constructors

Constructor and Description
LessLockingUniversalPgSQLQueueFactory()

Method Summary

Modifier and Type	Method and Description
protected LessLockingUniversalPgSQLQueue	createQueueInstance(QueueSpec spec) Creates a new queue instance.

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

disposeQueue, getDefaultDataSource, initQueue, setDefaultDataSource

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

createAndInitQueue, 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_FIFO

public static final String SPEC_FIELD_FIFO

See Also:

Constant Field Values

Constructor Detail

LessLockingUniversalPgSQLQueueFactory

public LessLockingUniversalPgSQLQueueFactory()

Method Detail

createQueueInstance

protected LessLockingUniversalPgSQLQueue createQueueInstance(QueueSpec spec)

Creates a new queue instance.

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

Specified by:

createQueueInstance in class AbstractQueueFactory<LessLockingUniversalPgSQLQueue>

Returns: