com.github.ddth.queue.impl.universal

Class UniversalJdbcQueueFactory

java.lang.Object

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

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

com.github.ddth.queue.impl.universal.UniversalJdbcQueueFactory

All Implemented Interfaces:

IQueueFactory

public class UniversalJdbcQueueFactory
extends JdbcQueueFactory<UniversalJdbcQueue>

Factory to create UniversalJdbcQueue instances.

Since:

0.4.1

Author:

Thanh Ba Nguyen

Field Summary

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
UniversalJdbcQueueFactory()

Method Summary

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

Constructor Detail

UniversalJdbcQueueFactory

public UniversalJdbcQueueFactory()

Method Detail

createQueueInstance

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

Returns: