net.greghaines.jesque.worker

Class DefaultFailQueueStrategy

java.lang.Object

net.greghaines.jesque.worker.DefaultFailQueueStrategy

All Implemented Interfaces:

FailQueueStrategy

public class DefaultFailQueueStrategy
extends Object
implements FailQueueStrategy

DefaultFailQueueStrategy puts all jobs in the standard Redis failure queue and imposes no limits on the max number of failed items to keep.

Constructor Summary

Constructors

Constructor and Description
DefaultFailQueueStrategy(String namespace) Constructor.

Method Summary

Modifier and Type	Method and Description
String	getFailQueueKey(Throwable thrwbl, Job job, String curQueue) Determine the key for the failure queue.
int	getFailQueueMaxItems(String curQueue) Determine the max number of items to keep in the failure queue.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultFailQueueStrategy

public DefaultFailQueueStrategy(String namespace)

Constructor.

Parameters:

namespace - the Redis namespace.

Method Detail

getFailQueueKey

public String getFailQueueKey(Throwable thrwbl,
                              Job job,
                              String curQueue)

Determine the key for the failure queue. A null return value is an indication that no failure queue is needed. Note that the default implementation (@see DefaultFailQueueStrategy) will never return null.

Specified by:

getFailQueueKey in interface FailQueueStrategy

Parameters:

thrwbl - the Throwable that occurred

job - the Job that failed

curQueue - the queue the Job came from

Returns:

the key of the failure queue to put the job into or null

getFailQueueMaxItems

public int getFailQueueMaxItems(String curQueue)

Determine the max number of items to keep in the failure queue. Returning a value less than 1 means that there is no limit.

Specified by:

getFailQueueMaxItems in interface FailQueueStrategy

Parameters:

curQueue - the queue the Job came from

Returns:

the max number of items to keep for the failure queue