net.greghaines.jesque.admin

Class AdminClientImpl

java.lang.Object

net.greghaines.jesque.admin.AbstractAdminClient

net.greghaines.jesque.admin.AdminClientImpl

All Implemented Interfaces:

AdminClient

public class AdminClientImpl
extends AbstractAdminClient

AdminClientImpl publishes jobs to channels.

Author:

Greg Haines

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	DEFAULT_CHECK_CONNECTION_BEFORE_USE The default behavior for checking connection validity before use.

Constructor Summary

Constructors

Constructor and Description
AdminClientImpl(Config config) Create a new AdminClientImpl, which creates it's own connection to Redis using values from the config.
AdminClientImpl(Config config, boolean checkConnectionBeforeUse) Create a new AdminClientImpl, which creates it's own connection to Redis using values from the config.
AdminClientImpl(Config config, long initialDelay, long period, TimeUnit timeUnit) Create a new AdminClientImpl, which creates it's own connection to Redis using values from the config and spawns a thread to ensure the connection stays open.

Method Summary

Modifier and Type	Method and Description
protected void	doPublish(String queue, 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

Field Detail

DEFAULT_CHECK_CONNECTION_BEFORE_USE

public static final boolean DEFAULT_CHECK_CONNECTION_BEFORE_USE

The default behavior for checking connection validity before use.

See Also:

Constant Field Values

Constructor Detail

AdminClientImpl

public AdminClientImpl(Config config)

Create a new AdminClientImpl, which creates it's own connection to Redis using values from the config. It will not verify the connection before use.

Parameters:

config - used to create a connection to Redis

AdminClientImpl

public AdminClientImpl(Config config,
                       boolean checkConnectionBeforeUse)

Create a new AdminClientImpl, which creates it's own connection to Redis using values from the config.

Parameters:

config - used to create a connection to Redis

checkConnectionBeforeUse - check to make sure the connection is alive before using it

Throws:

IllegalArgumentException - if the config is null

AdminClientImpl

public AdminClientImpl(Config config,
                       long initialDelay,
                       long period,
                       TimeUnit timeUnit)

Create a new AdminClientImpl, which creates it's own connection to Redis using values from the config and spawns a thread to ensure the connection stays open.

Parameters:

config - used to create a connection to Redis

initialDelay - the time to delay first connection check

period - the period between successive connection checks

timeUnit - the time unit of the initialDelay and period parameters

Method Detail

doPublish

protected void doPublish(String queue,
                         String jobJson)

Actually publish the serialized job.

Specified by:

doPublish in class AbstractAdminClient

Parameters:

queue - the queue to add the Job to

jobJson - the serialized Job

end

public void end()

Quits the connection to the Redis server.