net.greghaines.jesque.meta.dao

Interface QueueInfoDAO

All Known Implementing Classes:

QueueInfoDAORedisImpl

public interface QueueInfoDAO

QueueInfoDAO provides access to the queues in use by Jesque.

Author:

Greg Haines

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.

Method Detail

getQueueNames

List<String> getQueueNames()

Returns:

the list of queue names

getPendingCount

long getPendingCount()

Returns:

total number of jobs pending in all queues

getProcessedCount

long getProcessedCount()

Returns:

total number of jobs processed

getQueueInfos

List<QueueInfo> getQueueInfos()

Returns:

the list of queue informations

getQueueInfo

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

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

void removeQueue(String name)

Delete the given queue.

Parameters:

name - the name of the queue