Index (Jesque 2.0.2 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.
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.
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
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

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.
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.
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.
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.
checkQueues(Iterable<String>) - Static method in class net.greghaines.jesque.worker.WorkerImpl: 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 - Variable in class net.greghaines.jesque.worker.WorkerImpl
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.
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.
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_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_TIMEOUT - Static variable in class net.greghaines.jesque.ConfigBuilder: 5 seconds
DefaultExceptionHandler - Class in net.greghaines.jesque.worker: An ExceptionHandler that 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
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.
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.
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
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<T>, PoolUtils.PoolWork<T, V>) - Static method in class net.greghaines.jesque.utils.PoolUtils: Perform the given work with a resource from the given pool.
doWorkInPoolNicely(Pool<T>, PoolUtils.PoolWork<T, V>) - Static method in class net.greghaines.jesque.utils.PoolUtils: Perform the given work with a resource from the given pool.

E

EMPTY_QUEUE_SLEEP_TIME - Static variable in class net.greghaines.jesque.worker.WorkerImpl
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(boolean) - Method in class net.greghaines.jesque.admin.AdminImpl: 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.
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
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.worker.WorkerImpl: 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.
failure(Throwable, Job, String) - Method in class net.greghaines.jesque.worker.WorkerImpl: 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.

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
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
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 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.
getFailed() - Method in class net.greghaines.jesque.meta.WorkerInfo
getFailedAt() - Method in class net.greghaines.jesque.JobFailure
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
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 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.
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
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.
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
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
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.
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.WorkerStatus
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.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
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
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

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.
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.WorkerStatus
isProcessingJob() - Method in class net.greghaines.jesque.admin.AdminImpl: 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.
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 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.
isThreadNameChangingEnabled() - Static method in class net.greghaines.jesque.worker.WorkerImpl
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
jedisPubSub - Variable in class net.greghaines.jesque.admin.AdminImpl
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(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.

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.
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
LoggingWorkerListener - Class in net.greghaines.jesque.worker: An implementation of WorkerListener that logs every event that it is registered for.
lpoplpush(String, String) - Method in class net.greghaines.jesque.worker.WorkerImpl

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.worker.WorkerImpl
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
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: If there is a Throwable, it is logged as an error, otherwise it is logged as a debug message.
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 occurence of a registered WorkerEvent.
onException(JobExecutor, Exception, String) - Method in class net.greghaines.jesque.worker.DefaultExceptionHandler
onException(JobExecutor, Exception, String) - Method in interface net.greghaines.jesque.worker.ExceptionHandler
onMessage(String, String) - Method in class net.greghaines.jesque.admin.AdminImpl.PubSubListener
onPMessage(String, String, String) - Method in class net.greghaines.jesque.admin.AdminImpl.PubSubListener
onPSubscribe(String, int) - Method in class net.greghaines.jesque.admin.AdminImpl.PubSubListener
onPUnsubscribe(String, int) - Method in class net.greghaines.jesque.admin.AdminImpl.PubSubListener
onSubscribe(String, int) - Method in class net.greghaines.jesque.admin.AdminImpl.PubSubListener
onUnsubscribe(String, int) - Method in class net.greghaines.jesque.admin.AdminImpl.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.
poll() - Method in class net.greghaines.jesque.worker.WorkerImpl: 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 resources.
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.
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.
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

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
QUEUES - Static variable in interface net.greghaines.jesque.utils.ResqueConstants

R

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
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.worker.WorkerImpl: Handle an exception that was thrown from inside WorkerImpl.poll()
RecoveryStrategy - Enum in net.greghaines.jesque.worker: 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)).
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.
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.
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.
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.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

S

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
setClassName(String) - Method in class net.greghaines.jesque.Job: Set the class name.
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 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.
setFailed(Long) - Method in class net.greghaines.jesque.meta.WorkerInfo
setFailedAt(Date) - Method in class net.greghaines.jesque.JobFailure: Set when the error occurred.
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.
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.
setQueues(Collection<String>) - Method in class net.greghaines.jesque.worker.WorkerImpl: Clear any current queues and poll the given queues.
setQueues(Collection<String>) - Method in class net.greghaines.jesque.worker.WorkerPool: Clear any current queues and poll the given queues.
setRetriedAt(Date) - Method in class net.greghaines.jesque.JobFailure: Set when the job was retried.
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.
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.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.worker.WorkerImpl
statusMsg(String, Job) - Method in class net.greghaines.jesque.worker.WorkerImpl: 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.

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.
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.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.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.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.
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.
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: Basic 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.
WorkerImpl(Config, Collection<String>, JobFactory, Jedis) - Constructor for class net.greghaines.jesque.worker.WorkerImpl: Creates a new WorkerImpl, with the given connection to Redis.
WorkerImplFactory - Class in net.greghaines.jesque.worker: A simple 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: This class keeps track of WorkerListeners and notifies each listener when fireEvent() is invoked.
WorkerListenerDelegate() - Constructor for class net.greghaines.jesque.worker.WorkerListenerDelegate: Create a new WorkerListenerDelegate.
WorkerPool - Class in net.greghaines.jesque.worker: 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.
workerRef - Variable in class net.greghaines.jesque.admin.AdminImpl
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