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

Nested Class Summary

Nested classes/interfaces inherited from class AbstractAdminClient

AbstractAdminClient.Publisher

Constructor Summary

Constructors

Constructor	Description
AdminClientPoolImpl(Config config, UnifiedJedis jedisPool)	Create a new AdminClientPoolImpl using the supplied configuration and connection pool.

Method Summary

Modifier and Type	Method	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 AbstractAdminClient

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

Methods inherited from class Object

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

Constructor Details

AdminClientPoolImpl

public AdminClientPoolImpl(Config config,
 UnifiedJedis 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 Details

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.