net.greghaines.jesque.client

Class ClientPoolImpl

java.lang.Object

net.greghaines.jesque.client.AbstractClient

net.greghaines.jesque.client.ClientPoolImpl

All Implemented Interfaces:

Client

public class ClientPoolImpl
extends AbstractClient

A Client implementation that gets its connection to Redis from a connection pool.

Author:

Greg Haines, Animesh Kumar

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	doAcquireLock(String lockName, String lockHolder, int timeout) Actually acquire the lock based upon the client acquisition model.
protected void	doDelayedEnqueue(String queue, String msg, long future)
protected void	doEnqueue(String queue, String jobJson) Actually enqueue the serialized job.
protected void	doPriorityEnqueue(String queue, String jobJson) Actually enqueue the serialized job with high priority.
protected void	doRecurringEnqueue(String queue, String msg, long future, long frequency)
protected void	doRemoveDelayedEnqueue(String queue, String msg)
protected void	doRemoveRecurringEnqueue(String queue, String msg)
void	end() Quits the connection to the Redis server.

Methods inherited from class net.greghaines.jesque.client.AbstractClient

acquireLock, delayedEnqueue, doAcquireLock, doDelayedEnqueue, doEnqueue, doPriorityEnqueue, doRecurringEnqueue, doRemoveDelayedEnqueue, doRemoveRecurringEnqueue, enqueue, getNamespace, key, priorityEnqueue, recurringEnqueue, removeDelayedEnqueue, removeRecurringEnqueue

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientPoolImpl

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

Create a ClientPoolImpl.

Parameters:

config - used to get the namespace for key creation

jedisPool - the connection pool

Method Detail

doEnqueue

protected void doEnqueue(String queue,
             String jobJson)
                  throws Exception

Actually enqueue the serialized job.

Specified by:

doEnqueue in class AbstractClient

Parameters:

queue - the queue to add the Job to

jobJson - the serialized Job

Throws:

Exception - in case something goes wrong

doPriorityEnqueue

protected void doPriorityEnqueue(String queue,
                     String jobJson)
                          throws Exception

Actually enqueue the serialized job with high priority.

Specified by:

doPriorityEnqueue in class AbstractClient

Parameters:

queue - the queue to add the Job to

jobJson - the serialized Job

Throws:

Exception - in case something goes wrong

doAcquireLock

protected boolean doAcquireLock(String lockName,
                    String lockHolder,
                    int timeout)
                         throws Exception

Actually acquire the lock based upon the client acquisition model.

Specified by:

doAcquireLock in class AbstractClient

Parameters:

lockName - the name of the lock to acquire

lockHolder - a unique string identifying the caller

timeout - number of seconds until the lock will expire

Returns:

true, if the lock was acquired, false otherwise

Throws:

Exception - in case something goes wrong

end

public void end()

Quits the connection to the Redis server.

doDelayedEnqueue

protected void doDelayedEnqueue(String queue,
                    String msg,
                    long future)
                         throws Exception

Specified by:

doDelayedEnqueue in class AbstractClient

Throws:

Exception

doRemoveDelayedEnqueue

protected void doRemoveDelayedEnqueue(String queue,
                          String msg)
                               throws Exception

Specified by:

doRemoveDelayedEnqueue in class AbstractClient

Throws:

Exception

doRecurringEnqueue

protected void doRecurringEnqueue(String queue,
                      String msg,
                      long future,
                      long frequency)
                           throws Exception

Specified by:

doRecurringEnqueue in class AbstractClient

Throws:

Exception

doRemoveRecurringEnqueue

protected void doRemoveRecurringEnqueue(String queue,
                            String msg)
                                 throws Exception

Specified by:

doRemoveRecurringEnqueue in class AbstractClient

Throws:

Exception