net.greghaines.jesque.admin

Class AdminClientPoolImpl

java.lang.Object

net.greghaines.jesque.admin.AbstractAdminClient

net.greghaines.jesque.admin.AdminClientPoolImpl

All Implemented Interfaces:

AdminClient

public class AdminClientPoolImpl
extends AbstractAdminClient

AdminClientPoolImpl publishes jobs to channels using a connection pool.

Author:

Greg Haines

Constructor Summary

Constructors

Constructor and Description
AdminClientPoolImpl(Config config, redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool) Create a new AdminClientPoolImpl using the supplied configuration and connection pool.

Method Summary

Modifier and Type	Method and Description
protected void	doPublish(String channel, String jobJson) Actually publish the serialized job.
void	end() Quits the connection to the Redis server.

Methods inherited from class net.greghaines.jesque.admin.AbstractAdminClient

doPublish, getNamespace, publish, publish, shutdownWorkers, shutdownWorkers, togglePausedWorkers, togglePausedWorkers

Methods inherited from class java.lang.Object

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

Constructor Detail

AdminClientPoolImpl

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

Create a new AdminClientPoolImpl using the supplied configuration and connection pool.

Parameters:

config - used to create a connection to Redis

jedisPool - the Redis connection pool

Method Detail

doPublish

protected void doPublish(String channel,
                         String jobJson)
                  throws Exception

Actually publish the serialized job.

Specified by:

doPublish in class AbstractAdminClient

Parameters:

channel - the queue to add the Job to

jobJson - the serialized Job

Throws:

Exception - in case something goes wrong

end

public void end()

Quits the connection to the Redis server.