com.github.ddth.queue.impl.universal

Class LessLockingUniversalMySQLQueueFactory

java.lang.Object

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

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

com.github.ddth.queue.impl.universal.LessLockingUniversalMySQLQueueFactory

All Implemented Interfaces:

IQueueFactory

public class LessLockingUniversalMySQLQueueFactory
extends JdbcQueueFactory<LessLockingUniversalMySQLQueue>

Factory to create LessLockingUniversalMySQLQueue 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
LessLockingUniversalMySQLQueueFactory()

Method Summary

Modifier and Type	Method and Description
protected LessLockingUniversalMySQLQueue	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

LessLockingUniversalMySQLQueueFactory

public LessLockingUniversalMySQLQueueFactory()

Method Detail

createQueueInstance

protected LessLockingUniversalMySQLQueue 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<LessLockingUniversalMySQLQueue>

Returns: