Index (Jesque 2.1.3 API)

A B C D E F G H I J K L M N O P Q R S T U V W

A

AbstractAdminClient - Class in net.greghaines.jesque.admin: Common logic for AdminClient implementations.
AbstractAdminClient(Config) - Constructor for class net.greghaines.jesque.admin.AbstractAdminClient
AbstractClient - Class in net.greghaines.jesque.client: Common logic for Client implementations.
AbstractClient(Config) - Constructor for class net.greghaines.jesque.client.AbstractClient: Constructor.
acquireLock(String, String, int) - Method in class net.greghaines.jesque.client.AbstractClient: Acquire a non-blocking distributed lock.
acquireLock(String, String, int) - Method in interface net.greghaines.jesque.client.Client: Acquire a non-blocking distributed lock.
add(E) - Method in class net.greghaines.jesque.utils.ConcurrentHashSet
addAll(Collection<? extends E>) - Method in class net.greghaines.jesque.utils.ConcurrentHashSet
addJobType(String, Class<?>) - Method in class net.greghaines.jesque.worker.MapBasedJobFactory: Allow the given job type to be executed.
addListener(WorkerListener) - Method in interface net.greghaines.jesque.worker.WorkerEventEmitter: Register a WorkerListener for all WorkerEvents.
addListener(WorkerListener, WorkerEvent...) - Method in interface net.greghaines.jesque.worker.WorkerEventEmitter: Register a WorkerListener for the specified WorkerEvents.
addListener(WorkerListener) - Method in class net.greghaines.jesque.worker.WorkerListenerDelegate: Register a WorkerListener for all WorkerEvents.
addListener(WorkerListener, WorkerEvent...) - Method in class net.greghaines.jesque.worker.WorkerListenerDelegate: Register a WorkerListener for the specified WorkerEvents.
addQueue(String) - Method in interface net.greghaines.jesque.worker.Worker: Poll the given queue.
addQueue(String) - Method in class net.greghaines.jesque.worker.WorkerImpl: Poll the given queue.
addQueue(String) - Method in class net.greghaines.jesque.worker.WorkerPool: Poll the given queue.
addQueue(String) - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Poll the given queue.
Admin - Interface in net.greghaines.jesque.admin: Admin is an interface to receive administrative jobs for a worker.
ADMIN_CHANNEL - Static variable in interface net.greghaines.jesque.utils.ResqueConstants: Default channel for admin jobs
AdminClient - Interface in net.greghaines.jesque.admin: An AdminClient publishes jobs to channels.
AdminClientImpl - Class in net.greghaines.jesque.admin: AdminClientImpl publishes jobs to channels.
AdminClientImpl(Config) - Constructor for class net.greghaines.jesque.admin.AdminClientImpl: Create a new AdminClientImpl, which creates it's own connection to Redis using values from the config.
AdminClientImpl(Config, boolean) - Constructor for class net.greghaines.jesque.admin.AdminClientImpl: Create a new AdminClientImpl, which creates it's own connection to Redis using values from the config.
AdminClientImpl(Config, long, long, TimeUnit) - Constructor for class net.greghaines.jesque.admin.AdminClientImpl: 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.
AdminClientPoolImpl - Class in net.greghaines.jesque.admin: AdminClientPoolImpl publishes jobs to channels using a connection pool.
AdminClientPoolImpl(Config, Pool<Jedis>) - Constructor for class net.greghaines.jesque.admin.AdminClientPoolImpl: Create a new AdminClientPoolImpl using the supplied configuration and connection pool.
AdminImpl - Class in net.greghaines.jesque.admin: AdminImpl receives administrative jobs for a worker.
AdminImpl(Config) - Constructor for class net.greghaines.jesque.admin.AdminImpl: Create a new AdminImpl which subscribes to ResqueConstants.ADMIN_CHANNEL, registers the PauseCommand and ShutdownCommand jobs, and creates a new Jedis connection.
AdminImpl(Config, Set<String>, JobFactory) - Constructor for class net.greghaines.jesque.admin.AdminImpl: Create a new AdminImpl which creates a new Jedis connection.
AdminImpl(Config, Set<String>, JobFactory, Jedis) - Constructor for class net.greghaines.jesque.admin.AdminImpl: Create a new AdminImpl.
AdminImpl.PubSubListener - Class in net.greghaines.jesque.admin
AdminPoolImpl - Class in net.greghaines.jesque.admin: AdminPoolImpl receives administrative jobs for a worker using a connection pool.
AdminPoolImpl(Config, Pool<Jedis>) - Constructor for class net.greghaines.jesque.admin.AdminPoolImpl: Create a new AdminImpl which subscribes to ResqueConstants.ADMIN_CHANNEL, registers the PauseCommand and ShutdownCommand jobs.
AdminPoolImpl(Config, Set<String>, JobFactory, Pool<Jedis>) - Constructor for class net.greghaines.jesque.admin.AdminPoolImpl: Create a new AdminImpl.
AdminPoolImpl.PubSubListener - Class in net.greghaines.jesque.admin
ALL_QUEUES - Static variable in interface net.greghaines.jesque.worker.Worker: Special value to tell a Worker to poll all currently available queues.
AmbiguousConstructorException - Exception in net.greghaines.jesque.utils: Thrown when there is more than one matching Constructor is found.
AmbiguousConstructorException(String) - Constructor for exception net.greghaines.jesque.utils.AmbiguousConstructorException: Create a new AmbiguousConstructorException with only a message.
AmbiguousConstructorException(Class<?>, Object[], Set<Constructor<?>>) - Constructor for exception net.greghaines.jesque.utils.AmbiguousConstructorException: Create a new AmbiguousConstructorException with the possible Constructor options.
ARRAY_SUFFIX - Static variable in class net.greghaines.jesque.utils.ReflectionUtils: Suffix for array class names: "[]"

B

batchEnqueue(String, List<Job>) - Method in class net.greghaines.jesque.client.AbstractClient: Queues jobs in a given queue to be run.
batchEnqueue(String, List<Job>) - Method in interface net.greghaines.jesque.client.Client: Queues jobs in a given queue to be run.
build() - Method in class net.greghaines.jesque.ConfigBuilder

C

call() - Method in class net.greghaines.jesque.worker.WorkerImplFactory: Create a new WorkerImpl using the arguments provided to this factory's constructor.
call() - Method in class net.greghaines.jesque.worker.WorkerPoolImplFactory: Create a new WorkerPoolImpl using the arguments provided to this factory's constructor.
canUseAsDelayedQueue(Jedis, String) - Static method in class net.greghaines.jesque.utils.JedisUtils: Determines if the queue identified by the given key can be used as a delayed queue.
canUseAsRecurringQueue(Jedis, String, String) - Static method in class net.greghaines.jesque.utils.JedisUtils
CHANNEL - Static variable in interface net.greghaines.jesque.utils.ResqueConstants
checkChannels(Iterable<String>) - Static method in class net.greghaines.jesque.admin.AdminImpl: Verify that the given channels are all valid.
checkChannels(Iterable<String>) - Static method in class net.greghaines.jesque.admin.AdminPoolImpl: Verify that the given channels are all valid.
checkJobType(String, Class<?>) - Method in class net.greghaines.jesque.worker.MapBasedJobFactory: Determine if a job name and job type are valid.
checkJobTypes(Map<String, ? extends Class<?>>) - Method in class net.greghaines.jesque.worker.MapBasedJobFactory: Verify the given job types are all valid.
checkPaused() - Method in class net.greghaines.jesque.worker.WorkerImpl: Checks to see if worker is paused.
checkPaused() - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Checks to see if worker is paused.
checkQueues(Iterable<String>) - Static method in class net.greghaines.jesque.worker.WorkerImpl: Verify that the given queues are all valid.
checkQueues(Iterable<String>) - Static method in class net.greghaines.jesque.worker.WorkerPoolImpl: Verify that the given queues are all valid.
clear() - Method in interface net.greghaines.jesque.meta.dao.FailureDAO: Clear the list of failures.
clear() - Method in class net.greghaines.jesque.meta.dao.impl.FailureDAORedisImpl: Clear the list of failures.
clear() - Method in class net.greghaines.jesque.utils.ConcurrentHashSet
Client - Interface in net.greghaines.jesque.client: A Client allows Jobs to be enqueued for execution by Workers.
ClientImpl - Class in net.greghaines.jesque.client: Basic implementation of the Client interface.
ClientImpl(Config) - Constructor for class net.greghaines.jesque.client.ClientImpl: Create a new ClientImpl, which creates it's own connection to Redis using values from the config.
ClientImpl(Config, boolean) - Constructor for class net.greghaines.jesque.client.ClientImpl: Create a new ClientImpl, which creates it's own connection to Redis using values from the config.
ClientImpl(Config, long, long, TimeUnit) - Constructor for class net.greghaines.jesque.client.ClientImpl: Create a new ClientImpl, which creates it's own connection to Redis using values from the config and spawns a thread to ensure the connection stays open.
ClientPoolImpl - Class in net.greghaines.jesque.client: A Client implementation that gets its connection to Redis from a connection pool.
ClientPoolImpl(Config, Pool<Jedis>) - Constructor for class net.greghaines.jesque.client.ClientPoolImpl: Create a ClientPoolImpl.
COLON - Static variable in interface net.greghaines.jesque.utils.ResqueConstants
compareTo(KeyInfo) - Method in class net.greghaines.jesque.meta.KeyInfo
compareTo(QueueInfo) - Method in class net.greghaines.jesque.meta.QueueInfo
compareTo(WorkerInfo) - Method in class net.greghaines.jesque.meta.WorkerInfo
CompositeDateFormat - Class in net.greghaines.jesque.utils: CompositeDateFormat attempts to parse dates using several known date format patterns and formats dates using ResqueDateFormatThreadLocal.getInstance().
CompositeDateFormat() - Constructor for class net.greghaines.jesque.utils.CompositeDateFormat
ConcurrentHashSet<E> - Class in net.greghaines.jesque.utils: An implementation of ConcurrentSet that is backed by a ConcurrentHashMap.
ConcurrentHashSet() - Constructor for class net.greghaines.jesque.utils.ConcurrentHashSet: Creates a new, empty set with a default initial capacity (16), load factor (0.75) and concurrencyLevel (16).
ConcurrentHashSet(int) - Constructor for class net.greghaines.jesque.utils.ConcurrentHashSet: Creates a new, empty set with the specified initial capacity, and with default load factor (0.75) and concurrencyLevel (16).
ConcurrentHashSet(int, float) - Constructor for class net.greghaines.jesque.utils.ConcurrentHashSet: Creates a new, empty set with the specified initial capacity and load factor and with the default concurrencyLevel (16).
ConcurrentHashSet(int, float, int) - Constructor for class net.greghaines.jesque.utils.ConcurrentHashSet: Creates a new, empty set with the specified initial capacity, load factor and concurrency level.
ConcurrentHashSet(Collection<? extends E>) - Constructor for class net.greghaines.jesque.utils.ConcurrentHashSet: Creates a new set with the same entries as the given collection.
ConcurrentSet<E> - Interface in net.greghaines.jesque.utils: An interface that denotes the implementation of Set is thread-safe.
It adds no new methods.
Config - Class in net.greghaines.jesque: An immutable configuration bean for use with the rest of the project.
Config(String, int, int, String, String, int) - Constructor for class net.greghaines.jesque.Config: Using a ConfigBuilder is recommended...
Config(Set<String>, String, int, String, String, int) - Constructor for class net.greghaines.jesque.Config: Using a ConfigBuilder is recommended...
config - Variable in class net.greghaines.jesque.worker.WorkerImpl
config - Variable in class net.greghaines.jesque.worker.WorkerPoolImpl
ConfigBuilder - Class in net.greghaines.jesque: A fluent-style builder for Configs.
ConfigBuilder() - Constructor for class net.greghaines.jesque.ConfigBuilder: No-arg constructor.
ConfigBuilder(Config) - Constructor for class net.greghaines.jesque.ConfigBuilder: Create a new ConfigBuilder using an existing Config as the starting point.
contains(Object) - Method in class net.greghaines.jesque.utils.ConcurrentHashSet
containsAll(Collection<?>) - Method in class net.greghaines.jesque.utils.ConcurrentHashSet
createBacktrace(Throwable) - Static method in class net.greghaines.jesque.utils.JesqueUtils: Creates a Resque backtrace from a Throwable's stack trace.
createJedisPool(Config) - Static method in class net.greghaines.jesque.utils.PoolUtils: A simple helper method that creates a pool of connections to Redis using the supplied Config and the default pool config.
createJedisPool(Config, GenericObjectPoolConfig) - Static method in class net.greghaines.jesque.utils.PoolUtils: A simple helper method that creates a pool of connections to Redis using the supplied configurations.
createKey(String, String...) - Static method in class net.greghaines.jesque.utils.JesqueUtils: Builds a namespaced Redis key with the given arguments.
createKey(String, Iterable<String>) - Static method in class net.greghaines.jesque.utils.JesqueUtils: Builds a namespaced Redis key with the given arguments.
createName() - Method in class net.greghaines.jesque.worker.WorkerImpl: Creates a unique name, suitable for use with Resque.
createName() - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Creates a unique name, suitable for use with Resque.
createObject(Class<T>, Object...) - Static method in class net.greghaines.jesque.utils.ReflectionUtils: Create an object of the given type using a constructor that matches the supplied arguments.
createObject(Class<T>, Object[], Map<String, Object>) - Static method in class net.greghaines.jesque.utils.ReflectionUtils: Create an object of the given type using a constructor that matches the supplied arguments and invoke the setters with the supplied variables.
createRecurringHashKey(String) - Static method in class net.greghaines.jesque.utils.JesqueUtils
createWorker(String, Jedis) - Method in class net.greghaines.jesque.meta.dao.impl.WorkerInfoDAORedisImpl

D

DATE_FORMAT - Static variable in interface net.greghaines.jesque.utils.ResqueConstants: ISO-8601 compliant format
DATE_FORMAT_PHP - Static variable in interface net.greghaines.jesque.utils.ResqueConstants: For interoperability with php-resque
DATE_FORMAT_RUBY_V1 - Static variable in interface net.greghaines.jesque.utils.ResqueConstants: For interoperability with Resque (ruby)
DATE_FORMAT_RUBY_V2 - Static variable in interface net.greghaines.jesque.utils.ResqueConstants: For interoperability with Resque (ruby)
DATE_FORMAT_RUBY_V3 - Static variable in interface net.greghaines.jesque.utils.ResqueConstants: For interoperability with Resque (ruby)
DATE_FORMAT_RUBY_V4 - Static variable in interface net.greghaines.jesque.utils.ResqueConstants: For interoperability with Resque (ruby)
DEFAULT_CHECK_CONNECTION_BEFORE_USE - Static variable in class net.greghaines.jesque.admin.AdminClientImpl: The default behavior for checking connection validity before use.
DEFAULT_CHECK_CONNECTION_BEFORE_USE - Static variable in class net.greghaines.jesque.client.ClientImpl
DEFAULT_DATABASE - Static variable in class net.greghaines.jesque.ConfigBuilder: 0
DEFAULT_HOST - Static variable in class net.greghaines.jesque.ConfigBuilder: localhost
DEFAULT_MASTERNAME - Static variable in class net.greghaines.jesque.ConfigBuilder: null
DEFAULT_NAMESPACE - Static variable in class net.greghaines.jesque.ConfigBuilder: All Resque clients use "resque" by default
DEFAULT_PASSWORD - Static variable in class net.greghaines.jesque.ConfigBuilder: null
DEFAULT_PORT - Static variable in class net.greghaines.jesque.ConfigBuilder: 6379
DEFAULT_SENTINELS - Static variable in class net.greghaines.jesque.ConfigBuilder: null
DEFAULT_TIMEOUT - Static variable in class net.greghaines.jesque.ConfigBuilder: 5 seconds
DefaultExceptionHandler - Class in net.greghaines.jesque.worker: DefaultExceptionHandler reconnects if there is a connection exception, proceeds if the exception was JSON-related or a thread interrupt and terminates if the executor is shutdown.
DefaultExceptionHandler() - Constructor for class net.greghaines.jesque.worker.DefaultExceptionHandler
DefaultFailQueueStrategy - Class in net.greghaines.jesque.worker: DefaultFailQueueStrategy puts all jobs in the standard Redis failure queue and imposes no limits on the max number of failed items to keep.
DefaultFailQueueStrategy(String) - Constructor for class net.greghaines.jesque.worker.DefaultFailQueueStrategy: Constructor.
DefaultPoolExceptionHandler - Class in net.greghaines.jesque.worker: DefaultPoolExceptionHandler reconnects if there is a connection exception, proceeds if the exception was JSON-related or a thread interrupt and terminates if the executor is shutdown.
DefaultPoolExceptionHandler() - Constructor for class net.greghaines.jesque.worker.DefaultPoolExceptionHandler
delayedEnqueue(String, Job, long) - Method in class net.greghaines.jesque.client.AbstractClient: Queues a job in a given queue to be run in the future.
delayedEnqueue(String, Job, long) - Method in interface net.greghaines.jesque.client.Client: Queues a job in a given queue to be run in the future.
DEVELOPMENT - Static variable in class net.greghaines.jesque.utils.VersionUtils: String for non-released versions.
doAcquireLock(String, String, int) - Method in class net.greghaines.jesque.client.AbstractClient: Actually acquire the lock based upon the client acquisition model.
doAcquireLock(Jedis, String, String, String, int) - Static method in class net.greghaines.jesque.client.AbstractClient: Helper method that encapsulates the logic to acquire a lock.
doAcquireLock(String, String, int) - Method in class net.greghaines.jesque.client.ClientImpl: Actually acquire the lock based upon the client acquisition model.
doAcquireLock(String, String, int) - Method in class net.greghaines.jesque.client.ClientPoolImpl: Actually acquire the lock based upon the client acquisition model.
doBatchEnqueue(String, List<String>) - Method in class net.greghaines.jesque.client.AbstractClient: Actually enqueue the serialized jobs.
doBatchEnqueue(Jedis, String, String, List<String>) - Static method in class net.greghaines.jesque.client.AbstractClient: Helper method that encapsulates the minimum logic for adding jobs to a queue.
doBatchEnqueue(String, List<String>) - Method in class net.greghaines.jesque.client.ClientImpl: Actually enqueue the serialized jobs.
doBatchEnqueue(String, List<String>) - Method in class net.greghaines.jesque.client.ClientPoolImpl
doDelayedEnqueue(Jedis, String, String, String, long) - Static method in class net.greghaines.jesque.client.AbstractClient
doDelayedEnqueue(String, String, long) - Method in class net.greghaines.jesque.client.AbstractClient
doDelayedEnqueue(String, String, long) - Method in class net.greghaines.jesque.client.ClientImpl
doDelayedEnqueue(String, String, long) - Method in class net.greghaines.jesque.client.ClientPoolImpl
doEnqueue(String, String) - Method in class net.greghaines.jesque.client.AbstractClient: Actually enqueue the serialized job.
doEnqueue(Jedis, String, String, String) - Static method in class net.greghaines.jesque.client.AbstractClient: Helper method that encapsulates the minimum logic for adding a job to a queue.
doEnqueue(String, String) - Method in class net.greghaines.jesque.client.ClientImpl: Actually enqueue the serialized job.
doEnqueue(String, String) - Method in class net.greghaines.jesque.client.ClientPoolImpl: Actually enqueue the serialized job.
doPriorityEnqueue(String, String) - Method in class net.greghaines.jesque.client.AbstractClient: Actually enqueue the serialized job with high priority.
doPriorityEnqueue(Jedis, String, String, String) - Static method in class net.greghaines.jesque.client.AbstractClient: Helper method that encapsulates the minimum logic for adding a high priority job to a queue.
doPriorityEnqueue(String, String) - Method in class net.greghaines.jesque.client.ClientImpl: Actually enqueue the serialized job with high priority.
doPriorityEnqueue(String, String) - Method in class net.greghaines.jesque.client.ClientPoolImpl: Actually enqueue the serialized job with high priority.
doPublish(String, String) - Method in class net.greghaines.jesque.admin.AbstractAdminClient: Actually publish the serialized job.
doPublish(Jedis, String, String, String) - Static method in class net.greghaines.jesque.admin.AbstractAdminClient: Helper method that encapsulates the minimum logic for publishing a job to a channel.
doPublish(String, String) - Method in class net.greghaines.jesque.admin.AdminClientImpl: Actually publish the serialized job.
doPublish(String, String) - Method in class net.greghaines.jesque.admin.AdminClientPoolImpl: Actually publish the serialized job.
doRecurringEnqueue(Jedis, String, String, String, long, long) - Static method in class net.greghaines.jesque.client.AbstractClient
doRecurringEnqueue(String, String, long, long) - Method in class net.greghaines.jesque.client.AbstractClient
doRecurringEnqueue(String, String, long, long) - Method in class net.greghaines.jesque.client.ClientImpl
doRecurringEnqueue(String, String, long, long) - Method in class net.greghaines.jesque.client.ClientPoolImpl
doRemoveDelayedEnqueue(Jedis, String, String, String) - Static method in class net.greghaines.jesque.client.AbstractClient
doRemoveDelayedEnqueue(String, String) - Method in class net.greghaines.jesque.client.AbstractClient
doRemoveDelayedEnqueue(String, String) - Method in class net.greghaines.jesque.client.ClientImpl
doRemoveDelayedEnqueue(String, String) - Method in class net.greghaines.jesque.client.ClientPoolImpl
doRemoveRecurringEnqueue(Jedis, String, String, String) - Static method in class net.greghaines.jesque.client.AbstractClient
doRemoveRecurringEnqueue(String, String) - Method in class net.greghaines.jesque.client.AbstractClient
doRemoveRecurringEnqueue(String, String) - Method in class net.greghaines.jesque.client.ClientImpl
doRemoveRecurringEnqueue(String, String) - Method in class net.greghaines.jesque.client.ClientPoolImpl
doWork(Jedis) - Method in class net.greghaines.jesque.meta.dao.impl.KeysDAORedisImpl.KeyDAOPoolWork: Do work with a pooled resource and return a result.
doWork(T) - Method in interface net.greghaines.jesque.utils.PoolUtils.PoolWork: Do work with a pooled resource and return a result.
doWorkInPool(Pool<Jedis>, PoolUtils.PoolWork<Jedis, V>) - Static method in class net.greghaines.jesque.utils.PoolUtils: Perform the given work with a Jedis connection from the given pool.
doWorkInPoolNicely(Pool<Jedis>, PoolUtils.PoolWork<Jedis, V>) - Static method in class net.greghaines.jesque.utils.PoolUtils: Perform the given work with a Jedis connection from the given pool.

E

EMPTY_QUEUE_SLEEP_TIME - Static variable in class net.greghaines.jesque.worker.WorkerImpl
EMPTY_QUEUE_SLEEP_TIME - Static variable in class net.greghaines.jesque.worker.WorkerPoolImpl
end() - Method in interface net.greghaines.jesque.admin.AdminClient: Quits the connection to the Redis server.
end() - Method in class net.greghaines.jesque.admin.AdminClientImpl: Quits the connection to the Redis server.
end() - Method in class net.greghaines.jesque.admin.AdminClientPoolImpl: Quits the connection to the Redis server.
end(boolean) - Method in class net.greghaines.jesque.admin.AdminImpl: Shutdown this JobExecutor.
end(boolean) - Method in class net.greghaines.jesque.admin.AdminPoolImpl: Shutdown this JobExecutor.
end() - Method in interface net.greghaines.jesque.client.Client: Quits the connection to the Redis server.
end() - Method in class net.greghaines.jesque.client.ClientImpl: Quits the connection to the Redis server.
end() - Method in class net.greghaines.jesque.client.ClientPoolImpl: Quits the connection to the Redis server.
end(boolean) - Method in interface net.greghaines.jesque.worker.JobExecutor: Shutdown this JobExecutor.
end(boolean) - Method in class net.greghaines.jesque.worker.WorkerImpl: Shutdown this Worker.
The worker cannot be started again; create a new worker in this case.
end(boolean) - Method in class net.greghaines.jesque.worker.WorkerPool: Shutdown this JobExecutor.
end(boolean) - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Shutdown this Worker.
The worker cannot be started again; create a new worker in this case.
endAndJoin(boolean, long) - Method in class net.greghaines.jesque.worker.WorkerPool: Shutdown this pool and wait millis time per thread or until all threads are finished if millis is 0.
enqueue(String, Job) - Method in class net.greghaines.jesque.client.AbstractClient: Queues a job in a given queue to be run.
enqueue(String, Job) - Method in interface net.greghaines.jesque.client.Client: Queues a job in a given queue to be run.
enqueue(Jedis, String, Job) - Method in class net.greghaines.jesque.meta.dao.impl.FailureDAORedisImpl
ensureJedisConnection(Jedis) - Static method in class net.greghaines.jesque.utils.JedisUtils: Ensure that the given connection is established.
entry(K, V) - Static method in class net.greghaines.jesque.utils.JesqueUtils: Creates a Map.Entry out of the given key and value.
equal(Throwable, Throwable) - Static method in class net.greghaines.jesque.utils.JesqueUtils: This is needed because Throwable doesn't override equals() and object equality is not what we want to test.
equals(Object) - Method in class net.greghaines.jesque.Config
equals(Object) - Method in class net.greghaines.jesque.Job
equals(Object) - Method in class net.greghaines.jesque.JobFailure
equals(Object) - Method in class net.greghaines.jesque.meta.KeyInfo
equals(Object) - Method in class net.greghaines.jesque.meta.QueueInfo
equals(Object) - Method in class net.greghaines.jesque.meta.WorkerInfo
equals(Object) - Method in class net.greghaines.jesque.WorkerStatus
ERROR - Static variable in class net.greghaines.jesque.utils.VersionUtils: String shown if there was an error determining the version.
ExceptionHandler - Interface in net.greghaines.jesque.worker: ExceptionHandler allows for customized handling of exceptions received by a Worker.
execute(Job, String, Object) - Method in class net.greghaines.jesque.admin.AdminImpl: Executes the given job.
execute(Job, String, Object) - Method in class net.greghaines.jesque.admin.AdminPoolImpl: Executes the given job.
execute(Job, String, Object) - Method in class net.greghaines.jesque.worker.WorkerImpl: Executes the given job.
execute(Job, String, Object) - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Executes the given job.

F

FAILED - Static variable in interface net.greghaines.jesque.utils.ResqueConstants
failMsg(Throwable, String, Job) - Method in class net.greghaines.jesque.worker.WorkerImpl: Create and serialize a JobFailure.
failMsg(Throwable, String, Job) - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Create and serialize a JobFailure.
FailQueueStrategy - Interface in net.greghaines.jesque.worker: FailQueueStrategy allows for configurable failure queues.
failure(Throwable, Job, String) - Method in class net.greghaines.jesque.worker.WorkerImpl: Update the status in Redis on failure.
failure(Throwable, Job, String) - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Update the status in Redis on failure.
FailureDAO - Interface in net.greghaines.jesque.meta.dao: FailureDAO provides access to job failures.
FailureDAORedisImpl - Class in net.greghaines.jesque.meta.dao.impl: Accesses failure information about Jesque/Resque from Redis.
FailureDAORedisImpl(Config, Pool<Jedis>) - Constructor for class net.greghaines.jesque.meta.dao.impl.FailureDAORedisImpl: Constructor.
fireEvent(WorkerEvent, Worker, String, Job, Object, Object, Throwable) - Method in class net.greghaines.jesque.worker.WorkerListenerDelegate: Notify all WorkerListeners currently registered for the given WorkerEvent.
format(Date, StringBuffer, FieldPosition) - Method in class net.greghaines.jesque.utils.CompositeDateFormat
forName(String) - Static method in class net.greghaines.jesque.utils.ReflectionUtils: Replacement for Class.forName() that also returns Class instances for primitives (like "int") and array class names (like "String[]").
forName(String, ClassLoader) - Static method in class net.greghaines.jesque.utils.ReflectionUtils: Replacement for Class.forName() that also returns Class instances for primitives (e.g."int") and array class names (e.g.
FREQUENCY - Static variable in interface net.greghaines.jesque.utils.ResqueConstants

G

get() - Static method in class net.greghaines.jesque.json.ObjectMapperFactory
getActiveWorkerCount() - Method in class net.greghaines.jesque.meta.dao.impl.WorkerInfoDAORedisImpl
getActiveWorkerCount() - Method in interface net.greghaines.jesque.meta.dao.WorkerInfoDAO
getActiveWorkerCount() - Method in class net.greghaines.jesque.worker.WorkerPool
getActiveWorkers() - Method in class net.greghaines.jesque.meta.dao.impl.WorkerInfoDAORedisImpl
getActiveWorkers() - Method in interface net.greghaines.jesque.meta.dao.WorkerInfoDAO
getAllWorkers() - Method in class net.greghaines.jesque.meta.dao.impl.WorkerInfoDAORedisImpl
getAllWorkers() - Method in interface net.greghaines.jesque.meta.dao.WorkerInfoDAO
getArgs() - Method in class net.greghaines.jesque.Job
getArgs() - Method in exception net.greghaines.jesque.utils.AmbiguousConstructorException
getArgs() - Method in exception net.greghaines.jesque.utils.NoSuchConstructorException
getArrayValue() - Method in class net.greghaines.jesque.meta.KeyInfo
getBacktrace() - Method in class net.greghaines.jesque.JobFailure
getChannels() - Method in interface net.greghaines.jesque.admin.Admin
getChannels() - Method in class net.greghaines.jesque.admin.AdminImpl
getChannels() - Method in class net.greghaines.jesque.admin.AdminPoolImpl
getClassName() - Method in class net.greghaines.jesque.Job
getCount() - Method in interface net.greghaines.jesque.meta.dao.FailureDAO
getCount() - Method in class net.greghaines.jesque.meta.dao.impl.FailureDAORedisImpl
getDatabase() - Method in class net.greghaines.jesque.Config
getDefaultClassLoader() - Static method in class net.greghaines.jesque.utils.ReflectionUtils: Return the default ClassLoader to use: typically the thread context ClassLoader, if available; the ClassLoader that loaded the ReflectionUtils class will be used as fallback.
getDefaultConfig() - Static method in class net.greghaines.jesque.ConfigBuilder
getDefaultPoolConfig() - Static method in class net.greghaines.jesque.utils.PoolUtils
getError() - Method in class net.greghaines.jesque.JobFailure
getExceptionHandler() - Method in class net.greghaines.jesque.admin.AdminImpl: The current exception handler.
getExceptionHandler() - Method in class net.greghaines.jesque.admin.AdminPoolImpl: The current exception handler.
getExceptionHandler() - Method in interface net.greghaines.jesque.worker.JobExecutor: The current exception handler.
getExceptionHandler() - Method in class net.greghaines.jesque.worker.WorkerImpl: The current exception handler.
getExceptionHandler() - Method in class net.greghaines.jesque.worker.WorkerPool: The current exception handler.
getExceptionHandler() - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: The current exception handler.
getFailed() - Method in class net.greghaines.jesque.meta.WorkerInfo
getFailedAt() - Method in class net.greghaines.jesque.JobFailure
getFailQueueKey(Throwable, Job, String) - Method in class net.greghaines.jesque.worker.DefaultFailQueueStrategy: Determine the key for the failure queue.
getFailQueueKey(Throwable, Job, String) - Method in interface net.greghaines.jesque.worker.FailQueueStrategy: Determine the key for the failure queue.
getFailQueueMaxItems(String) - Method in class net.greghaines.jesque.worker.DefaultFailQueueStrategy: Determine the max number of items to keep in the failure queue.
getFailQueueMaxItems(String) - Method in interface net.greghaines.jesque.worker.FailQueueStrategy: Determine the max number of items to keep in the failure queue.
getFailQueueStrategy() - Method in class net.greghaines.jesque.worker.WorkerImpl
getFailQueueStrategy() - Method in class net.greghaines.jesque.worker.WorkerPoolImpl
getFailures(long, long) - Method in interface net.greghaines.jesque.meta.dao.FailureDAO
getFailures(long, long) - Method in class net.greghaines.jesque.meta.dao.impl.FailureDAORedisImpl
getHost() - Method in class net.greghaines.jesque.Config
getHost() - Method in class net.greghaines.jesque.meta.WorkerInfo
getIdleWorkerCount() - Method in class net.greghaines.jesque.worker.WorkerPool
getInstance() - Static method in class net.greghaines.jesque.utils.ResqueDateFormatThreadLocal: NOTE: DateFormats returned from this method are for use by the caller's thread only.
getJobFactory() - Method in class net.greghaines.jesque.admin.AdminImpl: The job factory.
getJobFactory() - Method in class net.greghaines.jesque.admin.AdminPoolImpl: The job factory.
getJobFactory() - Method in interface net.greghaines.jesque.worker.JobExecutor: The job factory.
getJobFactory() - Method in class net.greghaines.jesque.worker.WorkerImpl: The job factory.
getJobFactory() - Method in class net.greghaines.jesque.worker.WorkerPool: The job factory.
getJobFactory() - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: The job factory.
getJobs() - Method in class net.greghaines.jesque.meta.QueueInfo
getJobTypes() - Method in class net.greghaines.jesque.worker.MapBasedJobFactory: The allowed job names and types that this JobExecutor will execute.
getKeyInfo(String) - Method in class net.greghaines.jesque.meta.dao.impl.KeysDAORedisImpl: Get basic key info.
getKeyInfo(String, int, int) - Method in class net.greghaines.jesque.meta.dao.impl.KeysDAORedisImpl: Get basic key info plus a sub-list of the array value for the key, if applicable.
getKeyInfo(String) - Method in interface net.greghaines.jesque.meta.dao.KeysDAO: Get basic key info.
getKeyInfo(String, int, int) - Method in interface net.greghaines.jesque.meta.dao.KeysDAO: Get basic key info plus a sub-list of the array value for the key, if applicable.
getKeyInfos() - Method in class net.greghaines.jesque.meta.dao.impl.KeysDAORedisImpl: Get basic info on all keys.
getKeyInfos() - Method in interface net.greghaines.jesque.meta.dao.KeysDAO: Get basic info on all keys.
getKeyTypeByValue(String) - Static method in enum net.greghaines.jesque.meta.KeyType
getMasterName() - Method in class net.greghaines.jesque.Config
getName() - Method in class net.greghaines.jesque.meta.KeyInfo
getName() - Method in class net.greghaines.jesque.meta.QueueInfo
getName() - Method in class net.greghaines.jesque.meta.WorkerInfo
getName() - Method in interface net.greghaines.jesque.worker.Worker: Returns the name of this Worker.
getName() - Method in class net.greghaines.jesque.worker.WorkerImpl: Returns the name of this Worker.
getName() - Method in class net.greghaines.jesque.worker.WorkerPool: Returns the name of this Worker.
getName() - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Returns the name of this Worker.
getNamespace() - Method in class net.greghaines.jesque.admin.AbstractAdminClient
getNamespace() - Method in class net.greghaines.jesque.client.AbstractClient
getNamespace() - Method in class net.greghaines.jesque.Config
getNamespace() - Method in class net.greghaines.jesque.meta.KeyInfo
getNextQueue() - Method in class net.greghaines.jesque.worker.WorkerImpl
getNextQueue() - Method in class net.greghaines.jesque.worker.WorkerPoolImpl
getOptions() - Method in exception net.greghaines.jesque.utils.AmbiguousConstructorException
getPassword() - Method in class net.greghaines.jesque.Config
getPausedWorkerCount() - Method in class net.greghaines.jesque.meta.dao.impl.WorkerInfoDAORedisImpl
getPausedWorkerCount() - Method in interface net.greghaines.jesque.meta.dao.WorkerInfoDAO
getPausedWorkers() - Method in class net.greghaines.jesque.meta.dao.impl.WorkerInfoDAORedisImpl
getPausedWorkers() - Method in interface net.greghaines.jesque.meta.dao.WorkerInfoDAO
getPayload() - Method in class net.greghaines.jesque.JobFailure
getPayload() - Method in class net.greghaines.jesque.WorkerStatus
getPending() - Method in class net.greghaines.jesque.meta.QueueInfo
getPendingCount() - Method in class net.greghaines.jesque.meta.dao.impl.QueueInfoDAORedisImpl
getPendingCount() - Method in interface net.greghaines.jesque.meta.dao.QueueInfoDAO
getPid() - Method in class net.greghaines.jesque.meta.WorkerInfo
getPort() - Method in class net.greghaines.jesque.Config
getProcessed() - Method in class net.greghaines.jesque.meta.WorkerInfo
getProcessedCount() - Method in class net.greghaines.jesque.meta.dao.impl.QueueInfoDAORedisImpl
getProcessedCount() - Method in interface net.greghaines.jesque.meta.dao.QueueInfoDAO
getQueue() - Method in class net.greghaines.jesque.JobFailure
getQueue() - Method in class net.greghaines.jesque.WorkerStatus
getQueueInfo(String, long, long) - Method in class net.greghaines.jesque.meta.dao.impl.QueueInfoDAORedisImpl
getQueueInfo(String, long, long) - Method in interface net.greghaines.jesque.meta.dao.QueueInfoDAO
getQueueInfos() - Method in class net.greghaines.jesque.meta.dao.impl.QueueInfoDAORedisImpl
getQueueInfos() - Method in interface net.greghaines.jesque.meta.dao.QueueInfoDAO
getQueueNames() - Method in class net.greghaines.jesque.meta.dao.impl.QueueInfoDAORedisImpl
getQueueNames() - Method in interface net.greghaines.jesque.meta.dao.QueueInfoDAO
getQueues() - Method in class net.greghaines.jesque.meta.WorkerInfo
getQueues() - Method in interface net.greghaines.jesque.worker.Worker: The queues that this Worker will poll.
getQueues() - Method in class net.greghaines.jesque.worker.WorkerImpl: The queues that this Worker will poll.
getQueues() - Method in class net.greghaines.jesque.worker.WorkerPool: The queues that this Worker will poll.
getQueues() - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: The queues that this Worker will poll.
getReconnectAttempts() - Method in class net.greghaines.jesque.admin.AdminImpl
getReconnectAttempts() - Method in class net.greghaines.jesque.worker.WorkerImpl
getRedisInfo() - Method in class net.greghaines.jesque.meta.dao.impl.KeysDAORedisImpl
getRedisInfo() - Method in interface net.greghaines.jesque.meta.dao.KeysDAO
getRetriedAt() - Method in class net.greghaines.jesque.JobFailure
getRunAt() - Method in class net.greghaines.jesque.Job
getRunAt() - Method in class net.greghaines.jesque.WorkerStatus
getSentinels() - Method in class net.greghaines.jesque.Config
getSize() - Method in class net.greghaines.jesque.meta.KeyInfo
getSize() - Method in class net.greghaines.jesque.meta.QueueInfo
getStarted() - Method in class net.greghaines.jesque.meta.WorkerInfo
getState() - Method in class net.greghaines.jesque.meta.WorkerInfo
getStatus() - Method in class net.greghaines.jesque.meta.WorkerInfo
getThrowable() - Method in class net.greghaines.jesque.JobFailure
getThrowableString() - Method in class net.greghaines.jesque.JobFailure
getTimeout() - Method in class net.greghaines.jesque.Config
getType() - Method in class net.greghaines.jesque.meta.KeyInfo
getType() - Method in exception net.greghaines.jesque.utils.AmbiguousConstructorException
getType() - Method in exception net.greghaines.jesque.utils.NoSuchConstructorException
getType() - Method in exception net.greghaines.jesque.worker.UnpermittedJobException
getUnknownField(String) - Method in class net.greghaines.jesque.Job: Get an unknown field.
getUnknownFields() - Method in class net.greghaines.jesque.Job: Get all unknown fields.
getURI() - Method in class net.greghaines.jesque.Config
getVars() - Method in class net.greghaines.jesque.Job
getVersion() - Static method in class net.greghaines.jesque.utils.VersionUtils
getWorker() - Method in interface net.greghaines.jesque.admin.Admin
getWorker() - Method in class net.greghaines.jesque.admin.AdminImpl
getWorker() - Method in class net.greghaines.jesque.admin.AdminPoolImpl
getWorker() - Method in class net.greghaines.jesque.JobFailure
getWorker(String) - Method in class net.greghaines.jesque.meta.dao.impl.WorkerInfoDAORedisImpl
getWorker(String) - Method in interface net.greghaines.jesque.meta.dao.WorkerInfoDAO
getWorkerCount() - Method in class net.greghaines.jesque.meta.dao.impl.WorkerInfoDAORedisImpl
getWorkerCount() - Method in interface net.greghaines.jesque.meta.dao.WorkerInfoDAO
getWorkerCount() - Method in class net.greghaines.jesque.worker.WorkerPool
getWorkerEventEmitter() - Method in interface net.greghaines.jesque.worker.Worker
getWorkerEventEmitter() - Method in class net.greghaines.jesque.worker.WorkerImpl
getWorkerEventEmitter() - Method in class net.greghaines.jesque.worker.WorkerPool
getWorkerEventEmitter() - Method in class net.greghaines.jesque.worker.WorkerPoolImpl
getWorkerHostMap() - Method in class net.greghaines.jesque.meta.dao.impl.WorkerInfoDAORedisImpl
getWorkerHostMap() - Method in interface net.greghaines.jesque.meta.dao.WorkerInfoDAO
getWorkerId() - Method in class net.greghaines.jesque.worker.WorkerImpl
getWorkerId() - Method in class net.greghaines.jesque.worker.WorkerPoolImpl

H

handleHash(Jedis) - Method in class net.greghaines.jesque.meta.dao.impl.KeysDAORedisImpl.KeyDAOPoolWork
handleList(Jedis) - Method in class net.greghaines.jesque.meta.dao.impl.KeysDAORedisImpl.KeyDAOPoolWork
handleSet(Jedis) - Method in class net.greghaines.jesque.meta.dao.impl.KeysDAORedisImpl.KeyDAOPoolWork
handleString(Jedis) - Method in class net.greghaines.jesque.meta.dao.impl.KeysDAORedisImpl.KeyDAOPoolWork
handleZSet(Jedis) - Method in class net.greghaines.jesque.meta.dao.impl.KeysDAORedisImpl.KeyDAOPoolWork
hashCode() - Method in class net.greghaines.jesque.Config
hashCode() - Method in class net.greghaines.jesque.Job
hashCode() - Method in class net.greghaines.jesque.JobFailure
hashCode() - Method in class net.greghaines.jesque.meta.KeyInfo
hashCode() - Method in class net.greghaines.jesque.meta.QueueInfo
hashCode() - Method in class net.greghaines.jesque.meta.WorkerInfo
hashCode() - Method in class net.greghaines.jesque.WorkerStatus

I

INFLIGHT - Static variable in interface net.greghaines.jesque.utils.ResqueConstants
initialValue() - Method in class net.greghaines.jesque.utils.ResqueDateFormatThreadLocal
INSTANCE - Static variable in class net.greghaines.jesque.worker.LoggingWorkerListener
instantiateThrowable(String, String, Throwable, StackTraceElement[]) - Static method in class net.greghaines.jesque.utils.JesqueUtils
invokeSetters(T, Map<String, Object>) - Static method in class net.greghaines.jesque.utils.ReflectionUtils: Invoke the setters for the given variables on the given instance.
isAssignable(Class<?>, Class<?>) - Static method in class net.greghaines.jesque.utils.ReflectionUtils: Check if the right-hand side type may be assigned to the left-hand side type, assuming setting by reflection.
isAssignableValue(Class<?>, Object) - Static method in class net.greghaines.jesque.utils.ReflectionUtils: Determine if the given type is assignable from the given value, assuming setting by reflection.
isDelayed() - Method in class net.greghaines.jesque.meta.QueueInfo
isDelayedQueue(Jedis, String) - Static method in class net.greghaines.jesque.utils.JedisUtils: Determines if the queue identified by the given key is a delayed queue.
isEmpty() - Method in class net.greghaines.jesque.utils.ConcurrentHashSet
isKeyUsed(Jedis, String) - Static method in class net.greghaines.jesque.utils.JedisUtils: Determines if the queue identified by the given key is used.
isPaused() - Method in interface net.greghaines.jesque.worker.Worker: Returns whether this worker is paused.
isPaused() - Method in class net.greghaines.jesque.worker.WorkerImpl: Returns whether this worker is paused.
isPaused() - Method in class net.greghaines.jesque.worker.WorkerPool: Returns whether this worker is paused.
isPaused() - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Returns whether this worker is paused.
isPaused() - Method in class net.greghaines.jesque.WorkerStatus
isProcessingJob() - Method in class net.greghaines.jesque.admin.AdminImpl: Returns whether this JobExecutor is currently processing a job.
isProcessingJob() - Method in class net.greghaines.jesque.admin.AdminPoolImpl: Returns whether this JobExecutor is currently processing a job.
isProcessingJob() - Method in interface net.greghaines.jesque.worker.JobExecutor: Returns whether this JobExecutor is currently processing a job.
isProcessingJob() - Method in class net.greghaines.jesque.worker.WorkerImpl: Returns whether this JobExecutor is currently processing a job.
isProcessingJob() - Method in class net.greghaines.jesque.worker.WorkerPool: Returns whether this JobExecutor is currently processing a job.
isProcessingJob() - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Returns whether this JobExecutor is currently processing a job.
isRecurringQueue(Jedis, String, String) - Static method in class net.greghaines.jesque.utils.JedisUtils
isRegularQueue(Jedis, String) - Static method in class net.greghaines.jesque.utils.JedisUtils: Determines if the queue identified by the given key is a regular queue.
isShutdown() - Method in class net.greghaines.jesque.admin.AdminImpl: Returns whether this JobExecutor is either shutdown or in the process of shutting down.
isShutdown() - Method in class net.greghaines.jesque.admin.AdminPoolImpl: Returns whether this JobExecutor is either shutdown or in the process of shutting down.
isShutdown() - Method in interface net.greghaines.jesque.worker.JobExecutor: Returns whether this JobExecutor is either shutdown or in the process of shutting down.
isShutdown() - Method in class net.greghaines.jesque.worker.WorkerImpl: Returns whether this JobExecutor is either shutdown or in the process of shutting down.
isShutdown() - Method in class net.greghaines.jesque.worker.WorkerPool: Returns whether this JobExecutor is either shutdown or in the process of shutting down.
isShutdown() - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Returns whether this JobExecutor is either shutdown or in the process of shutting down.
isThreadNameChangingEnabled() - Static method in class net.greghaines.jesque.worker.WorkerImpl
isThreadNameChangingEnabled() - Static method in class net.greghaines.jesque.worker.WorkerPoolImpl
isValid() - Method in class net.greghaines.jesque.Job
isWorkerInState(String, WorkerInfo.State, Jedis) - Method in class net.greghaines.jesque.meta.dao.impl.WorkerInfoDAORedisImpl
iterator() - Method in class net.greghaines.jesque.utils.ConcurrentHashSet

J

JAVA_DYNAMIC_QUEUES - Static variable in interface net.greghaines.jesque.utils.ResqueConstants
jedis - Variable in class net.greghaines.jesque.admin.AdminImpl
jedis - Variable in class net.greghaines.jesque.worker.WorkerImpl
jedisPool - Variable in class net.greghaines.jesque.admin.AdminPoolImpl
jedisPool - Variable in class net.greghaines.jesque.worker.WorkerPoolImpl
jedisPubSub - Variable in class net.greghaines.jesque.admin.AdminImpl
jedisPubSub - Variable in class net.greghaines.jesque.admin.AdminPoolImpl
JedisUtils - Class in net.greghaines.jesque.utils: A collection of utilities for Redis connections.
JesqueUtils - Class in net.greghaines.jesque.utils: Miscellaneous utilities.
Job - Class in net.greghaines.jesque: A simple class to describe a job to be run by a worker.
Job() - Constructor for class net.greghaines.jesque.Job: No-argument constructor.
Job(Job) - Constructor for class net.greghaines.jesque.Job: Cloning constructor.
Job(String, List<?>) - Constructor for class net.greghaines.jesque.Job: A convenience constructor.
Job(String, Object...) - Constructor for class net.greghaines.jesque.Job: Create a new Job with the given class name and arguments.
Job(String, Map<String, ? extends Object>) - Constructor for class net.greghaines.jesque.Job: Create a new Job with the given class name and named arguments.
Resque 2.0-style Job.
Job(String, Object[], Map<String, ? extends Object>) - Constructor for class net.greghaines.jesque.Job: Create a new Job with the given class name and both types of arguments.
Resque 2.0-style Job.
JobExecutor - Interface in net.greghaines.jesque.worker: JobExecutor is an object that executes jobs.
JobExecutor.State - Enum in net.greghaines.jesque.worker: States of the job executor.
JobFactory - Interface in net.greghaines.jesque.worker: JobFactory materializes jobs.
JobFailure - Class in net.greghaines.jesque: A bean to hold information about a job that failed.
JobFailure() - Constructor for class net.greghaines.jesque.JobFailure: No-argument constructor.
JobFailure(JobFailure) - Constructor for class net.greghaines.jesque.JobFailure: Cloning constructor.
join(long) - Method in class net.greghaines.jesque.admin.AdminImpl: Wait for this JobExecutor to complete.
join(long) - Method in class net.greghaines.jesque.admin.AdminPoolImpl: Wait for this JobExecutor to complete.
join(String, String...) - Static method in class net.greghaines.jesque.utils.JesqueUtils: Join the given strings, separated by the given separator.
join(String, Iterable<String>) - Static method in class net.greghaines.jesque.utils.JesqueUtils: Join the given strings, separated by the given separator.
join(long) - Method in interface net.greghaines.jesque.worker.JobExecutor: Wait for this JobExecutor to complete.
join(long) - Method in class net.greghaines.jesque.worker.WorkerImpl: Wait for this JobExecutor to complete.
join(long) - Method in class net.greghaines.jesque.worker.WorkerPool: Join to internal threads and wait millis time per thread or until all threads are finished if millis is 0.
join(long) - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Wait for this JobExecutor to complete.

K

key(String...) - Method in class net.greghaines.jesque.client.AbstractClient: Builds a namespaced Redis key with the given arguments.
key(String...) - Method in class net.greghaines.jesque.worker.WorkerImpl: Builds a namespaced Redis key with the given arguments.
key(String...) - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Builds a namespaced Redis key with the given arguments.
KeyDAOPoolWork(String) - Constructor for class net.greghaines.jesque.meta.dao.impl.KeysDAORedisImpl.KeyDAOPoolWork
KeyDAOPoolWork(String, int, int) - Constructor for class net.greghaines.jesque.meta.dao.impl.KeysDAORedisImpl.KeyDAOPoolWork
KeyInfo - Class in net.greghaines.jesque.meta: Information about a key in Redis.
KeyInfo() - Constructor for class net.greghaines.jesque.meta.KeyInfo: No-argument constructor.
KeyInfo(String, KeyType) - Constructor for class net.greghaines.jesque.meta.KeyInfo: Constructor.
KeysDAO - Interface in net.greghaines.jesque.meta.dao: KeysDAO provides access to available keys.
KeysDAORedisImpl - Class in net.greghaines.jesque.meta.dao.impl: KeysDAORedisImpl gets key information from Redis.
KeysDAORedisImpl(Config, Pool<Jedis>) - Constructor for class net.greghaines.jesque.meta.dao.impl.KeysDAORedisImpl: Constructor.
KeysDAORedisImpl.KeyDAOPoolWork - Class in net.greghaines.jesque.meta.dao.impl
KeyType - Enum in net.greghaines.jesque.meta: KeyTypes are the types of Redis keys that Jesque uses.

L

listenerDelegate - Variable in class net.greghaines.jesque.worker.WorkerImpl
listenerDelegate - Variable in class net.greghaines.jesque.worker.WorkerPoolImpl
loadRedisScripts(Jedis) - Method in class net.greghaines.jesque.worker.WorkerPoolImpl
loadRedisScripts() - Method in class net.greghaines.jesque.worker.WorkerPoolImpl
LoggingWorkerListener - Class in net.greghaines.jesque.worker: LoggingWorkerListener logs every event that it is registered for.
lpoplpush(String, String) - Method in class net.greghaines.jesque.worker.WorkerImpl
lpoplpush(Jedis, String, String) - Method in class net.greghaines.jesque.worker.WorkerPoolImpl

M

map(Map.Entry<? extends K, ? extends V>...) - Static method in class net.greghaines.jesque.utils.JesqueUtils: A convenient way of creating a map on the fly.
MapBasedJobFactory - Class in net.greghaines.jesque.worker: MapBasedJobFactory uses a map of job names and types to materialize jobs.
MapBasedJobFactory(Map<String, ? extends Class<?>>) - Constructor for class net.greghaines.jesque.worker.MapBasedJobFactory: Constructor.
materializeJob(Job) - Static method in class net.greghaines.jesque.utils.JesqueUtils: Materializes a job by assuming the Job.getClassName() is a fully-qualified Java type.
materializeJob(Job, Map<String, Class<?>>) - Static method in class net.greghaines.jesque.utils.JesqueUtils: Materializes a job by looking up Job.getClassName() in the provided map of job types.
materializeJob(Job) - Method in interface net.greghaines.jesque.worker.JobFactory: Materializes a job.
materializeJob(Job) - Method in class net.greghaines.jesque.worker.MapBasedJobFactory: Materializes a job.
materializeJob(Job) - Method in class net.greghaines.jesque.worker.ReflectiveJobFactory: Materializes a job.

N

namespace - Variable in class net.greghaines.jesque.admin.AdminImpl
namespace - Variable in class net.greghaines.jesque.admin.AdminPoolImpl
namespace - Variable in class net.greghaines.jesque.worker.WorkerImpl
namespace - Variable in class net.greghaines.jesque.worker.WorkerPoolImpl
net.greghaines.jesque - package net.greghaines.jesque
net.greghaines.jesque.admin - package net.greghaines.jesque.admin
net.greghaines.jesque.admin.commands - package net.greghaines.jesque.admin.commands
net.greghaines.jesque.client - package net.greghaines.jesque.client
net.greghaines.jesque.json - package net.greghaines.jesque.json
net.greghaines.jesque.meta - package net.greghaines.jesque.meta
net.greghaines.jesque.meta.dao - package net.greghaines.jesque.meta.dao
net.greghaines.jesque.meta.dao.impl - package net.greghaines.jesque.meta.dao.impl
net.greghaines.jesque.utils - package net.greghaines.jesque.utils
net.greghaines.jesque.worker - package net.greghaines.jesque.worker
NextQueueStrategy - Enum in net.greghaines.jesque.worker: Strategies to determine the next queue a Worker will poll.
NoSuchConstructorException - Exception in net.greghaines.jesque.utils: Thrown when the specified constructor could not be found.
NoSuchConstructorException(String) - Constructor for exception net.greghaines.jesque.utils.NoSuchConstructorException: Create a new NoSuchConstructorException with only a message.
NoSuchConstructorException(Class<?>, Object...) - Constructor for exception net.greghaines.jesque.utils.NoSuchConstructorException: Create a new NoSuchConstructorException with the type and arguments.
nullSafeEquals(Object, Object) - Static method in class net.greghaines.jesque.utils.JesqueUtils: Test for equality.

O

ObjectMapperFactory - Class in net.greghaines.jesque.json: A helper that creates a fully-configured singleton ObjectMapper.
onEvent(WorkerEvent, Worker, String, Job, Object, Object, Throwable) - Method in class net.greghaines.jesque.worker.LoggingWorkerListener: This method is called by the Worker upon the occurrence of a registered WorkerEvent.
onEvent(WorkerEvent, Worker, String, Job, Object, Object, Throwable) - Method in interface net.greghaines.jesque.worker.WorkerListener: This method is called by the Worker upon the occurrence of a registered WorkerEvent.
onException(JobExecutor, Exception, String) - Method in class net.greghaines.jesque.worker.DefaultExceptionHandler: Called when a worker encounters an exception.
onException(JobExecutor, Exception, String) - Method in class net.greghaines.jesque.worker.DefaultPoolExceptionHandler: Called when a worker encounters an exception.
onException(JobExecutor, Exception, String) - Method in interface net.greghaines.jesque.worker.ExceptionHandler: Called when a worker encounters an exception.
onMessage(String, String) - Method in class net.greghaines.jesque.admin.AdminImpl.PubSubListener
onMessage(String, String) - Method in class net.greghaines.jesque.admin.AdminPoolImpl.PubSubListener
onPMessage(String, String, String) - Method in class net.greghaines.jesque.admin.AdminImpl.PubSubListener
onPMessage(String, String, String) - Method in class net.greghaines.jesque.admin.AdminPoolImpl.PubSubListener
onPSubscribe(String, int) - Method in class net.greghaines.jesque.admin.AdminImpl.PubSubListener
onPSubscribe(String, int) - Method in class net.greghaines.jesque.admin.AdminPoolImpl.PubSubListener
onPUnsubscribe(String, int) - Method in class net.greghaines.jesque.admin.AdminImpl.PubSubListener
onPUnsubscribe(String, int) - Method in class net.greghaines.jesque.admin.AdminPoolImpl.PubSubListener
onSubscribe(String, int) - Method in class net.greghaines.jesque.admin.AdminImpl.PubSubListener
onSubscribe(String, int) - Method in class net.greghaines.jesque.admin.AdminPoolImpl.PubSubListener
onUnsubscribe(String, int) - Method in class net.greghaines.jesque.admin.AdminImpl.PubSubListener
onUnsubscribe(String, int) - Method in class net.greghaines.jesque.admin.AdminPoolImpl.PubSubListener

P

parse(String, ParsePosition) - Method in class net.greghaines.jesque.utils.CompositeDateFormat
PauseCommand - Class in net.greghaines.jesque.admin.commands: Pause the worker that receives this job.
PauseCommand(boolean) - Constructor for class net.greghaines.jesque.admin.commands.PauseCommand: Constructor.
pauseMsg() - Method in class net.greghaines.jesque.worker.WorkerImpl: Create and serialize a WorkerStatus for a pause event.
pauseMsg() - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Create and serialize a WorkerStatus for a pause event.
poll() - Method in class net.greghaines.jesque.worker.WorkerImpl: Polls the queues for jobs and executes them.
poll() - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Polls the queues for jobs and executes them.
PONG - Static variable in class net.greghaines.jesque.utils.JedisUtils
PoolUtils - Class in net.greghaines.jesque.utils: Convenience methods for doing work with pooled Jedis connections.
PoolUtils.PoolWork<T,V> - Interface in net.greghaines.jesque.utils: A unit of work that utilizes a pooled resource.
pop(String) - Method in class net.greghaines.jesque.worker.WorkerImpl: Remove a job from the given queue.
pop(String) - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Remove a job from the given queue.
priorityEnqueue(String, Job) - Method in class net.greghaines.jesque.client.AbstractClient: Queues a job with high priority in a given queue to be run.
priorityEnqueue(String, Job) - Method in interface net.greghaines.jesque.client.Client: Queues a job with high priority in a given queue to be run.
process(Job, String) - Method in class net.greghaines.jesque.worker.WorkerImpl: Materializes and executes the given job.
process(Job, String) - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Materializes and executes the given job.
PROCESSED - Static variable in interface net.greghaines.jesque.utils.ResqueConstants
publish(Job) - Method in class net.greghaines.jesque.admin.AbstractAdminClient: Publishes a job on the ResqueConstants.ADMIN_CHANNEL channel.
publish(String, Job) - Method in class net.greghaines.jesque.admin.AbstractAdminClient: Publishes a job on the given channel.
publish(Job) - Method in interface net.greghaines.jesque.admin.AdminClient: Publishes a job on the ResqueConstants.ADMIN_CHANNEL channel.
publish(String, Job) - Method in interface net.greghaines.jesque.admin.AdminClient: Publishes a job on the given channel.
PubSubListener() - Constructor for class net.greghaines.jesque.admin.AdminImpl.PubSubListener
PubSubListener() - Constructor for class net.greghaines.jesque.admin.AdminPoolImpl.PubSubListener

Q

QUEUE - Static variable in interface net.greghaines.jesque.utils.ResqueConstants
QueueInfo - Class in net.greghaines.jesque.meta: Information about the current state of a queue.
QueueInfo() - Constructor for class net.greghaines.jesque.meta.QueueInfo
QueueInfoDAO - Interface in net.greghaines.jesque.meta.dao: QueueInfoDAO provides access to the queues in use by Jesque.
QueueInfoDAORedisImpl - Class in net.greghaines.jesque.meta.dao.impl: QueueInfoDAORedisImpl gets queue information from Redis.
QueueInfoDAORedisImpl(Config, Pool<Jedis>) - Constructor for class net.greghaines.jesque.meta.dao.impl.QueueInfoDAORedisImpl: Constructor.
queueNames - Variable in class net.greghaines.jesque.worker.WorkerImpl
queueNames - Variable in class net.greghaines.jesque.worker.WorkerPoolImpl
QUEUES - Static variable in interface net.greghaines.jesque.utils.ResqueConstants

R

readScript(String) - Static method in class net.greghaines.jesque.utils.ScriptUtils: Read a script into a single-line string suitable for use in a Redis EVAL statement.
reconnect(Jedis, int, long) - Static method in class net.greghaines.jesque.utils.JedisUtils: Attempt to reconnect to Redis.
RECONNECT_ATTEMPTS - Static variable in class net.greghaines.jesque.worker.WorkerImpl
RECONNECT_SLEEP_TIME - Static variable in class net.greghaines.jesque.worker.WorkerImpl
RECONNECT_SLEEP_TIME - Static variable in class net.greghaines.jesque.worker.WorkerPoolImpl
recoverFromException(String, Exception) - Method in class net.greghaines.jesque.admin.AdminImpl: Handle an exception that was thrown from inside AdminImpl.PubSubListener.onMessage(String,String).
recoverFromException(String, Exception) - Method in class net.greghaines.jesque.admin.AdminPoolImpl: Handle an exception that was thrown from inside AdminPoolImpl.PubSubListener.onMessage(String,String).
recoverFromException(String, Exception) - Method in class net.greghaines.jesque.worker.WorkerImpl: Handle an exception that was thrown from inside WorkerImpl.poll().
recoverFromException(String, Exception) - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Handle an exception that was thrown from inside WorkerPoolImpl.poll().
RecoveryStrategy - Enum in net.greghaines.jesque.worker: RecoveryStrategy are the possible means for a worker to recover from an error.
recreateStackTrace(List<String>) - Static method in class net.greghaines.jesque.utils.JesqueUtils
recreateThrowable(String, String, List<String>) - Static method in class net.greghaines.jesque.utils.JesqueUtils: Recreate an exception from a type name, a message and a backtrace (created from JesqueUtils.createBacktrace(Throwable)).
recurringEnqueue(String, Job, long, long) - Method in class net.greghaines.jesque.client.AbstractClient: Queues a job to be in the future and recur
recurringEnqueue(String, Job, long, long) - Method in interface net.greghaines.jesque.client.Client: Queues a job to be in the future and recur
ReflectionUtils - Class in net.greghaines.jesque.utils: Reflection utilities.
ReflectiveJobFactory - Class in net.greghaines.jesque.worker: ReflectiveJobFactory assumes job names are fully-qualified class names.
ReflectiveJobFactory() - Constructor for class net.greghaines.jesque.worker.ReflectiveJobFactory
remove(long) - Method in interface net.greghaines.jesque.meta.dao.FailureDAO: Remove a failure from the list.
remove(long) - Method in class net.greghaines.jesque.meta.dao.impl.FailureDAORedisImpl: Remove a failure from the list.
remove(Object) - Method in class net.greghaines.jesque.utils.ConcurrentHashSet
removeAll(Collection<?>) - Method in class net.greghaines.jesque.utils.ConcurrentHashSet
removeAllListeners() - Method in interface net.greghaines.jesque.worker.WorkerEventEmitter: Unregister all WorkerListeners for all WorkerEvents.
removeAllListeners(WorkerEvent...) - Method in interface net.greghaines.jesque.worker.WorkerEventEmitter: Unregister all WorkerListeners for the specified WorkerEvents.
removeAllListeners() - Method in class net.greghaines.jesque.worker.WorkerListenerDelegate: Unregister all WorkerListeners for all WorkerEvents.
removeAllListeners(WorkerEvent...) - Method in class net.greghaines.jesque.worker.WorkerListenerDelegate: Unregister all WorkerListeners for the specified WorkerEvents.
removeAllQueues() - Method in interface net.greghaines.jesque.worker.Worker: Stop polling all queues.
removeAllQueues() - Method in class net.greghaines.jesque.worker.WorkerImpl: Stop polling all queues.
removeAllQueues() - Method in class net.greghaines.jesque.worker.WorkerPool: Stop polling all queues.
removeAllQueues() - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Stop polling all queues.
removeDelayedEnqueue(String, Job) - Method in class net.greghaines.jesque.client.AbstractClient: Removes a queued future job.
removeDelayedEnqueue(String, Job) - Method in interface net.greghaines.jesque.client.Client: Removes a queued future job.
removeJobName(String) - Method in class net.greghaines.jesque.worker.MapBasedJobFactory: Disallow the job name from being executed.
removeJobType(Class<?>) - Method in class net.greghaines.jesque.worker.MapBasedJobFactory: Disallow the job type from being executed.
removeListener(WorkerListener) - Method in interface net.greghaines.jesque.worker.WorkerEventEmitter: Unregister a WorkerListener for all WorkerEvents.
removeListener(WorkerListener, WorkerEvent...) - Method in interface net.greghaines.jesque.worker.WorkerEventEmitter: Unregister a WorkerListener for the specified WorkerEvents.
removeListener(WorkerListener) - Method in class net.greghaines.jesque.worker.WorkerListenerDelegate: Unregister a WorkerListener for all WorkerEvents.
removeListener(WorkerListener, WorkerEvent...) - Method in class net.greghaines.jesque.worker.WorkerListenerDelegate: Unregister a WorkerListener for the specified WorkerEvents.
removeQueue(String) - Method in class net.greghaines.jesque.meta.dao.impl.QueueInfoDAORedisImpl: Delete the given queue.
removeQueue(String) - Method in interface net.greghaines.jesque.meta.dao.QueueInfoDAO: Delete the given queue.
removeQueue(String, boolean) - Method in interface net.greghaines.jesque.worker.Worker: Stop polling the given queue.
removeQueue(String, boolean) - Method in class net.greghaines.jesque.worker.WorkerImpl: Stop polling the given queue.
removeQueue(String, boolean) - Method in class net.greghaines.jesque.worker.WorkerPool: Stop polling the given queue.
removeQueue(String, boolean) - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Stop polling the given queue.
removeRecurringEnqueue(String, Job) - Method in class net.greghaines.jesque.client.AbstractClient
removeRecurringEnqueue(String, Job) - Method in interface net.greghaines.jesque.client.Client: Removes a queued recurring job.
removeWorker(String) - Method in class net.greghaines.jesque.meta.dao.impl.WorkerInfoDAORedisImpl: Removes the metadata about a worker.
removeWorker(String) - Method in interface net.greghaines.jesque.meta.dao.WorkerInfoDAO: Removes the metadata about a worker.
renameThread(String) - Method in class net.greghaines.jesque.worker.WorkerImpl: Rename the current thread with the given message.
renameThread(String) - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Rename the current thread with the given message.
requeue(long) - Method in interface net.greghaines.jesque.meta.dao.FailureDAO: Re-queue a job for execution.
requeue(long) - Method in class net.greghaines.jesque.meta.dao.impl.FailureDAORedisImpl: Re-queue a job for execution.
ResqueConstants - Interface in net.greghaines.jesque.utils: Constants used by Resque.
ResqueDateFormatThreadLocal - Class in net.greghaines.jesque.utils: Provides DateFormats configured for use with Resque.
retainAll(Collection<?>) - Method in class net.greghaines.jesque.utils.ConcurrentHashSet
run() - Method in class net.greghaines.jesque.admin.AdminImpl
run() - Method in class net.greghaines.jesque.admin.AdminPoolImpl
run() - Method in class net.greghaines.jesque.admin.commands.PauseCommand
run() - Method in class net.greghaines.jesque.admin.commands.ShutdownCommand
run() - Method in class net.greghaines.jesque.worker.WorkerImpl: Starts this worker.
run() - Method in class net.greghaines.jesque.worker.WorkerPool
run() - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Starts this worker.

S

ScriptUtils - Class in net.greghaines.jesque.utils: ScriptUtils contains utility methods for executing Lua scripts in Redis.
set(K...) - Static method in class net.greghaines.jesque.utils.JesqueUtils: Creates a Set out of the given keys
setArgs(Object...) - Method in class net.greghaines.jesque.Job: Set the arguments.
setArrayValue(List<String>) - Method in class net.greghaines.jesque.meta.KeyInfo
setBacktrace(List<String>) - Method in class net.greghaines.jesque.JobFailure: Set the backtrace of the throwable
setChannels(Set<String>) - Method in interface net.greghaines.jesque.admin.Admin
setChannels(Set<String>) - Method in class net.greghaines.jesque.admin.AdminImpl
setChannels(Set<String>) - Method in class net.greghaines.jesque.admin.AdminPoolImpl
setClassName(String) - Method in class net.greghaines.jesque.Job: Set the class name.
setDelayed(Boolean) - Method in class net.greghaines.jesque.meta.QueueInfo
setError(String) - Method in class net.greghaines.jesque.JobFailure: Set the error that occurred
setExceptionHandler(ExceptionHandler) - Method in class net.greghaines.jesque.admin.AdminImpl: Set this JobExecutor's exception handler to the given handler.
setExceptionHandler(ExceptionHandler) - Method in class net.greghaines.jesque.admin.AdminPoolImpl: Set this JobExecutor's exception handler to the given handler.
setExceptionHandler(ExceptionHandler) - Method in interface net.greghaines.jesque.worker.JobExecutor: Set this JobExecutor's exception handler to the given handler.
setExceptionHandler(ExceptionHandler) - Method in class net.greghaines.jesque.worker.WorkerImpl: Set this JobExecutor's exception handler to the given handler.
setExceptionHandler(ExceptionHandler) - Method in class net.greghaines.jesque.worker.WorkerPool: Set this JobExecutor's exception handler to the given handler.
setExceptionHandler(ExceptionHandler) - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Set this JobExecutor's exception handler to the given handler.
setFailed(Long) - Method in class net.greghaines.jesque.meta.WorkerInfo
setFailedAt(Date) - Method in class net.greghaines.jesque.JobFailure: Set when the error occurred.
setFailQueueStrategy(FailQueueStrategy) - Method in class net.greghaines.jesque.worker.WorkerImpl
setFailQueueStrategy(FailQueueStrategy) - Method in class net.greghaines.jesque.worker.WorkerPoolImpl
setHost(String) - Method in class net.greghaines.jesque.meta.WorkerInfo
setJobs(List<Job>) - Method in class net.greghaines.jesque.meta.QueueInfo
setJobTypes(Map<String, ? extends Class<?>>) - Method in class net.greghaines.jesque.worker.MapBasedJobFactory: Clear any current allowed job types and use the given set.
setName(String) - Method in class net.greghaines.jesque.meta.KeyInfo
setName(String) - Method in class net.greghaines.jesque.meta.QueueInfo
setName(String) - Method in class net.greghaines.jesque.meta.WorkerInfo
setNamespace(String) - Method in class net.greghaines.jesque.meta.KeyInfo
setPaused(boolean) - Method in class net.greghaines.jesque.WorkerStatus: Sets whether the worker is paused.
setPayload(Job) - Method in class net.greghaines.jesque.JobFailure: Set the job.
setPayload(Job) - Method in class net.greghaines.jesque.WorkerStatus: Set the job.
setPending(Long) - Method in class net.greghaines.jesque.meta.QueueInfo
setPid(String) - Method in class net.greghaines.jesque.meta.WorkerInfo
setProcessed(Long) - Method in class net.greghaines.jesque.meta.WorkerInfo
setQueue(String) - Method in class net.greghaines.jesque.JobFailure: Set the queue the job came from.
setQueue(String) - Method in class net.greghaines.jesque.WorkerStatus: Set which queue the current job came from.
setQueues(List<String>) - Method in class net.greghaines.jesque.meta.WorkerInfo
setQueues(Collection<String>) - Method in interface net.greghaines.jesque.worker.Worker: Clear any current queues and poll the given queues in the order returned by the Collection's iterator.
setQueues(Collection<String>) - Method in class net.greghaines.jesque.worker.WorkerImpl: Clear any current queues and poll the given queues in the order returned by the Collection's iterator.
setQueues(Collection<String>) - Method in class net.greghaines.jesque.worker.WorkerPool: Clear any current queues and poll the given queues in the order returned by the Collection's iterator.
setQueues(Collection<String>) - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Clear any current queues and poll the given queues in the order returned by the Collection's iterator.
setRetriedAt(Date) - Method in class net.greghaines.jesque.JobFailure: Set when the job was retried.
setRunAt(Double) - Method in class net.greghaines.jesque.Job
setRunAt(Date) - Method in class net.greghaines.jesque.WorkerStatus: Set when the Worker started on the current job.
setSize(Long) - Method in class net.greghaines.jesque.meta.KeyInfo
setSize(Long) - Method in class net.greghaines.jesque.meta.QueueInfo
setStarted(Date) - Method in class net.greghaines.jesque.meta.WorkerInfo
setState(WorkerInfo.State) - Method in class net.greghaines.jesque.meta.WorkerInfo
setStatus(WorkerStatus) - Method in class net.greghaines.jesque.meta.WorkerInfo
setThreadNameChangingEnabled(boolean) - Static method in class net.greghaines.jesque.worker.WorkerImpl: Enable/disable worker thread renaming during normal operation.
setThreadNameChangingEnabled(boolean) - Static method in class net.greghaines.jesque.worker.WorkerPoolImpl: Enable/disable worker thread renaming during normal operation.
setThrowable(Throwable) - Method in class net.greghaines.jesque.JobFailure: Set the throwable that occurred.
setThrowableString(String) - Method in class net.greghaines.jesque.JobFailure: Set the exception that occurred.
setType(KeyType) - Method in class net.greghaines.jesque.meta.KeyInfo
setUnknownField(String, Object) - Method in class net.greghaines.jesque.Job: Set an unknown field.
setUnknownFields(Map<String, Object>) - Method in class net.greghaines.jesque.Job: Set all unknown fields
setVars(Map<String, ? extends Object>) - Method in class net.greghaines.jesque.Job: Set the named arguments.
setWorker(Worker) - Method in interface net.greghaines.jesque.admin.Admin
setWorker(Worker) - Method in class net.greghaines.jesque.admin.AdminImpl
setWorker(Worker) - Method in class net.greghaines.jesque.admin.AdminPoolImpl
setWorker(Worker) - Method in class net.greghaines.jesque.admin.commands.PauseCommand
setWorker(Worker) - Method in class net.greghaines.jesque.admin.commands.ShutdownCommand
setWorker(String) - Method in class net.greghaines.jesque.JobFailure: Set the name of the worker where the job failed.
setWorker(Worker) - Method in interface net.greghaines.jesque.worker.WorkerAware
ShutdownCommand - Class in net.greghaines.jesque.admin.commands: Shuts down the worker that receives this job.
ShutdownCommand(boolean) - Constructor for class net.greghaines.jesque.admin.commands.ShutdownCommand: Constructor.
shutdownWorkers(boolean) - Method in class net.greghaines.jesque.admin.AbstractAdminClient: Send a shutdown command on the ResqueConstants.ADMIN_CHANNEL channel.
shutdownWorkers(String, boolean) - Method in class net.greghaines.jesque.admin.AbstractAdminClient: Send a shutdown command on the given channel.
shutdownWorkers(boolean) - Method in interface net.greghaines.jesque.admin.AdminClient: Send a shutdown command on the ResqueConstants.ADMIN_CHANNEL channel.
shutdownWorkers(String, boolean) - Method in interface net.greghaines.jesque.admin.AdminClient: Send a shutdown command on the given channel.
size() - Method in class net.greghaines.jesque.utils.ConcurrentHashSet
STARTED - Static variable in interface net.greghaines.jesque.utils.ResqueConstants
STAT - Static variable in interface net.greghaines.jesque.utils.ResqueConstants
state - Variable in class net.greghaines.jesque.admin.AdminImpl
state - Variable in class net.greghaines.jesque.admin.AdminPoolImpl
state - Variable in class net.greghaines.jesque.worker.WorkerImpl
state - Variable in class net.greghaines.jesque.worker.WorkerPoolImpl
statusMsg(String, Job) - Method in class net.greghaines.jesque.worker.WorkerImpl: Create and serialize a WorkerStatus.
statusMsg(String, Job) - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Create and serialize a WorkerStatus.
success(Job, Object, Object, String) - Method in class net.greghaines.jesque.worker.WorkerImpl: Update the status in Redis on success.
success(Job, Object, Object, String) - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Update the status in Redis on success.

T

testJedisConnection(Jedis) - Static method in class net.greghaines.jesque.utils.JedisUtils: Test if a connection is valid.
toArray() - Method in class net.greghaines.jesque.utils.ConcurrentHashSet
toArray(T[]) - Method in class net.greghaines.jesque.utils.ConcurrentHashSet
togglePause(boolean) - Method in interface net.greghaines.jesque.worker.Worker: Toggle whether this worker will process any new jobs.
togglePause(boolean) - Method in class net.greghaines.jesque.worker.WorkerImpl: Toggle whether this worker will process any new jobs.
togglePause(boolean) - Method in class net.greghaines.jesque.worker.WorkerPool: Toggle whether this worker will process any new jobs.
togglePause(boolean) - Method in class net.greghaines.jesque.worker.WorkerPoolImpl: Toggle whether this worker will process any new jobs.
togglePausedWorkers(boolean) - Method in class net.greghaines.jesque.admin.AbstractAdminClient: Send a pause command on the ResqueConstants.ADMIN_CHANNEL channel.
togglePausedWorkers(String, boolean) - Method in class net.greghaines.jesque.admin.AbstractAdminClient: Send a pause command on the given channel.
togglePausedWorkers(boolean) - Method in interface net.greghaines.jesque.admin.AdminClient: Send a pause command on the ResqueConstants.ADMIN_CHANNEL channel.
togglePausedWorkers(String, boolean) - Method in interface net.greghaines.jesque.admin.AdminClient: Send a pause command on the given channel.
toString() - Method in class net.greghaines.jesque.Config
toString() - Method in class net.greghaines.jesque.Job
toString() - Method in class net.greghaines.jesque.JobFailure
toString() - Method in class net.greghaines.jesque.meta.KeyInfo
toString() - Method in enum net.greghaines.jesque.meta.KeyType
toString() - Method in class net.greghaines.jesque.meta.QueueInfo
toString() - Method in class net.greghaines.jesque.meta.WorkerInfo
toString() - Method in class net.greghaines.jesque.worker.WorkerImpl
toString() - Method in class net.greghaines.jesque.worker.WorkerPoolImpl
toString() - Method in class net.greghaines.jesque.WorkerStatus

U

UnpermittedJobException - Exception in net.greghaines.jesque.worker: Thrown by a Worker when it receives a Job that it is not allowed to run.
UnpermittedJobException(String) - Constructor for exception net.greghaines.jesque.worker.UnpermittedJobException: Create a new UnpermittedJobException with only a message.
UnpermittedJobException(Class<?>) - Constructor for exception net.greghaines.jesque.worker.UnpermittedJobException: Create a new UnpermittedJobException with the type.

V

valueOf(String) - Static method in enum net.greghaines.jesque.meta.KeyType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum net.greghaines.jesque.meta.WorkerInfo.State: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum net.greghaines.jesque.worker.JobExecutor.State: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum net.greghaines.jesque.worker.NextQueueStrategy: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum net.greghaines.jesque.worker.RecoveryStrategy: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum net.greghaines.jesque.worker.WorkerEvent: Returns the enum constant of this type with the specified name.
values() - Static method in enum net.greghaines.jesque.meta.KeyType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum net.greghaines.jesque.meta.WorkerInfo.State: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum net.greghaines.jesque.worker.JobExecutor.State: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum net.greghaines.jesque.worker.NextQueueStrategy: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum net.greghaines.jesque.worker.RecoveryStrategy: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum net.greghaines.jesque.worker.WorkerEvent: Returns an array containing the constants of this enum type, in the order they are declared.
VersionUtils - Class in net.greghaines.jesque.utils: Grabs the version number from the Maven metadata.

W

withDatabase(int) - Method in class net.greghaines.jesque.ConfigBuilder: Configs created by this ConfigBuilder will use the given Redis database.
withHost(String) - Method in class net.greghaines.jesque.ConfigBuilder: Configs created by this ConfigBuilder will have the given Redis hostname.
withMasterName(String) - Method in class net.greghaines.jesque.ConfigBuilder: Configs created by this ConfigBuilder will use the given Redis master name.
withNamespace(String) - Method in class net.greghaines.jesque.ConfigBuilder: Configs created by this ConfigBuilder will have the given Redis namespace to prefix keys with.
withPassword(String) - Method in class net.greghaines.jesque.ConfigBuilder: Configs created by this ConfigBuilder will authenticate with the given Redis password.
withPort(int) - Method in class net.greghaines.jesque.ConfigBuilder: Configs created by this ConfigBuilder will have the given Redis port number.
withSentinels(Set<String>) - Method in class net.greghaines.jesque.ConfigBuilder: Configs created by this ConfigBuilder will use the given Redis sentinels.
withTimeout(int) - Method in class net.greghaines.jesque.ConfigBuilder: Configs created by this ConfigBuilder will have the given Redis connection timeout.
WORKER - Static variable in interface net.greghaines.jesque.utils.ResqueConstants
Worker - Interface in net.greghaines.jesque.worker: A Worker polls for Jobs from a specified list of queues, executing them in sequence and notifying WorkerListeners in the process.
WorkerAware - Interface in net.greghaines.jesque.worker: WorkerAware indicates that a materialized Job should have the Worker executing the job injected before execution.
WorkerEvent - Enum in net.greghaines.jesque.worker: The possible WorkerEvents that a WorkerListener may register for.
WorkerEventEmitter - Interface in net.greghaines.jesque.worker: A WorkerEventEmitter allows WorkerListeners to register for WorkerEvents.
WorkerImpl - Class in net.greghaines.jesque.worker: WorkerImpl is an implementation of the Worker interface.
WorkerImpl(Config, Collection<String>, JobFactory) - Constructor for class net.greghaines.jesque.worker.WorkerImpl: Creates a new WorkerImpl, which creates it's own connection to Redis using values from the config.
The worker will only listen to the supplied queues and execute jobs that are provided by the given job factory.
WorkerImpl(Config, Collection<String>, JobFactory, Jedis) - Constructor for class net.greghaines.jesque.worker.WorkerImpl: Creates a new WorkerImpl, with the given connection to Redis.
The worker will only listen to the supplied queues and execute jobs that are provided by the given job factory.
WorkerImpl(Config, Collection<String>, JobFactory, Jedis, NextQueueStrategy) - Constructor for class net.greghaines.jesque.worker.WorkerImpl: Creates a new WorkerImpl, with the given connection to Redis.
The worker will only listen to the supplied queues and execute jobs that are provided by the given job factory.
WorkerImplFactory - Class in net.greghaines.jesque.worker: WorkerImplFactory is a factory for WorkerImpls.
WorkerImplFactory(Config, Collection<String>, JobFactory) - Constructor for class net.greghaines.jesque.worker.WorkerImplFactory: Create a new factory.
WorkerInfo - Class in net.greghaines.jesque.meta: Information about the current state of a worker.
WorkerInfo() - Constructor for class net.greghaines.jesque.meta.WorkerInfo
WorkerInfo.State - Enum in net.greghaines.jesque.meta: Possible states of a worker.
WorkerInfoDAO - Interface in net.greghaines.jesque.meta.dao: WorkerInfoDAO provides access to information about workers.
WorkerInfoDAORedisImpl - Class in net.greghaines.jesque.meta.dao.impl: WorkerInfoDAORedisImpl gets worker information from Redis.
WorkerInfoDAORedisImpl(Config, Pool<Jedis>) - Constructor for class net.greghaines.jesque.meta.dao.impl.WorkerInfoDAORedisImpl: Constructor.
WorkerListener - Interface in net.greghaines.jesque.worker: A WorkerListener can register with a Worker to be notified of WorkerEvents.
WorkerListenerDelegate - Class in net.greghaines.jesque.worker: WorkerListenerDelegate keeps track of WorkerListeners and notifies each listener when fireEvent() is invoked.
WorkerListenerDelegate() - Constructor for class net.greghaines.jesque.worker.WorkerListenerDelegate: Constructor.
WorkerPool - Class in net.greghaines.jesque.worker: WorkerPool creates a fixed number of identical Workers, each on a separate Thread.
WorkerPool(Callable<? extends Worker>, int) - Constructor for class net.greghaines.jesque.worker.WorkerPool: Create a WorkerPool with the given number of Workers and the default ThreadFactory.
WorkerPool(Callable<? extends Worker>, int, ThreadFactory) - Constructor for class net.greghaines.jesque.worker.WorkerPool: Create a WorkerPool with the given number of Workers and the given ThreadFactory.
WorkerPoolImpl - Class in net.greghaines.jesque.worker: WorkerPoolImpl is an implementation of the Worker interface that uses a connection pool.
WorkerPoolImpl(Config, Collection<String>, JobFactory, Pool<Jedis>) - Constructor for class net.greghaines.jesque.worker.WorkerPoolImpl: Creates a new WorkerImpl, with the given connection to Redis.
The worker will only listen to the supplied queues and execute jobs that are provided by the given job factory.
WorkerPoolImpl(Config, Collection<String>, JobFactory, Pool<Jedis>, NextQueueStrategy) - Constructor for class net.greghaines.jesque.worker.WorkerPoolImpl: Creates a new WorkerImpl, with the given connection to Redis.
The worker will only listen to the supplied queues and execute jobs that are provided by the given job factory.
WorkerPoolImplFactory - Class in net.greghaines.jesque.worker: WorkerPoolImplFactory is a factory for WorkerPoolImpls.
WorkerPoolImplFactory(Config, Collection<String>, JobFactory, Pool<Jedis>) - Constructor for class net.greghaines.jesque.worker.WorkerPoolImplFactory: Create a new factory.
workerRef - Variable in class net.greghaines.jesque.admin.AdminImpl
workerRef - Variable in class net.greghaines.jesque.admin.AdminPoolImpl
WORKERS - Static variable in interface net.greghaines.jesque.utils.ResqueConstants
WorkerStatus - Class in net.greghaines.jesque: A bean to hold information about the status of a Worker.
WorkerStatus() - Constructor for class net.greghaines.jesque.WorkerStatus: No-argument constructor.
WorkerStatus(WorkerStatus) - Constructor for class net.greghaines.jesque.WorkerStatus: Cloning constructor.

A B C D E F G H I J K L M N O P Q R S T U V W