net.greghaines.jesque.meta.dao.impl

Class QueueInfoDAORedisImpl

java.lang.Object

net.greghaines.jesque.meta.dao.impl.QueueInfoDAORedisImpl

All Implemented Interfaces:

QueueInfoDAO

public class QueueInfoDAORedisImpl
extends Object
implements QueueInfoDAO

QueueInfoDAORedisImpl gets queue information from Redis.

Author:

Greg Haines, Animesh Kumar

Constructor Summary

Constructors

Constructor and Description
QueueInfoDAORedisImpl(Config config, redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool) Constructor.

Method Summary

Modifier and Type	Method and Description
long	getPendingCount()
long	getProcessedCount()
QueueInfo	getQueueInfo(String name, long jobOffset, long jobCount)
List<QueueInfo>	getQueueInfos()
List<String>	getQueueNames()
void	removeQueue(String name) Delete the given queue.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QueueInfoDAORedisImpl

public QueueInfoDAORedisImpl(Config config,
                             redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool)

Constructor.

Parameters:

config - the Jesque configuration

jedisPool - the pool of Jedis connections

Method Detail

getQueueNames

public List<String> getQueueNames()

Specified by:

getQueueNames in interface QueueInfoDAO

Returns:

the list of queue names

getPendingCount

public long getPendingCount()

Specified by:

getPendingCount in interface QueueInfoDAO

Returns:

total number of jobs pending in all queues

getProcessedCount

public long getProcessedCount()

Specified by:

getProcessedCount in interface QueueInfoDAO

Returns:

total number of jobs processed

getQueueInfos

public List<QueueInfo> getQueueInfos()

Specified by:

getQueueInfos in interface QueueInfoDAO

Returns:

the list of queue informations

getQueueInfo

public QueueInfo getQueueInfo(String name,
                              long jobOffset,
                              long jobCount)

Specified by:

getQueueInfo in interface QueueInfoDAO

Parameters:

name - the queue name

jobOffset - the offset into the queue

jobCount - the number of jobs to return

Returns:

the queue information or null if the queue does not exist

removeQueue

public void removeQueue(String name)

Delete the given queue.

Specified by:

removeQueue in interface QueueInfoDAO

Parameters:

name - the name of the queue