public class DefaultQueueFactory extends java.lang.Object implements QueueFactory
SqliteJobQueue
and
one SimpleInMemoryPriorityQueue
both are wrapped inside a CachedJobQueue
to
improve performanceConstructor and Description |
---|
DefaultQueueFactory() |
DefaultQueueFactory(SqliteJobQueue.JobSerializer jobSerializer) |
Modifier and Type | Method and Description |
---|---|
JobQueue |
createNonPersistent(Configuration configuration,
long sessionId) |
JobQueue |
createPersistentQueue(Configuration configuration,
long sessionId) |
public DefaultQueueFactory()
public DefaultQueueFactory(SqliteJobQueue.JobSerializer jobSerializer)
public JobQueue createPersistentQueue(Configuration configuration, long sessionId)
createPersistentQueue
in interface QueueFactory
public JobQueue createNonPersistent(Configuration configuration, long sessionId)
createNonPersistent
in interface QueueFactory