net.greghaines.jesque.meta.dao.impl

Class FailureDAORedisImpl

java.lang.Object

net.greghaines.jesque.meta.dao.impl.FailureDAORedisImpl

All Implemented Interfaces:

FailureDAO

public class FailureDAORedisImpl
extends Object
implements FailureDAO

Accesses failure information about Jesque/Resque from Redis.

Author:

Greg Haines

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	clear() Clear the list of failures.
protected void	enqueue(redis.clients.jedis.Jedis jedis, String queue, Job job)
long	getCount()
List<JobFailure>	getFailures(long offset, long count)
void	remove(long index) Remove a failure from the list.
Date	requeue(long index) Re-queue a job for execution.

Methods inherited from class java.lang.Object

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

Constructor Detail

FailureDAORedisImpl

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

Constructor.

Parameters:

config - the Jesque configuration

jedisPool - the connection pool to Redis

Method Detail

getCount

public long getCount()

Specified by:

getCount in interface FailureDAO

Returns:

total number of failures

getFailures

public List<JobFailure> getFailures(long offset,
                                    long count)

Specified by:

getFailures in interface FailureDAO

Parameters:

offset - offset into the failures

count - number of failures to return

Returns:

a sub-list of the failures

clear

public void clear()

Clear the list of failures.

Specified by:

clear in interface FailureDAO

requeue

public Date requeue(long index)

Re-queue a job for execution.

Specified by:

requeue in interface FailureDAO

Parameters:

index - the index into the failure list

Returns:

the date the job was re-queued

remove

public void remove(long index)

Remove a failure from the list.

Specified by:

remove in interface FailureDAO

Parameters:

index - the index of the failure to remove

enqueue

protected void enqueue(redis.clients.jedis.Jedis jedis,
                       String queue,
                       Job job)
                throws IOException

Throws:

IOException