Index (Jesque 3.0.0 API)

A B C D E F G H I J K L M N O P Q R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

AbstractAdminClient - Class in net.greghaines.jesque.admin: Common logic for AdminClient implementations.
AbstractAdminClient(Config) - Constructor for class net.greghaines.jesque.admin.AbstractAdminClient
AbstractAdminClient.Publisher - Interface in net.greghaines.jesque.admin
AbstractClient - Class in net.greghaines.jesque.client: Common logic for Client implementations.
AbstractClient(Config) - Constructor for class net.greghaines.jesque.client.AbstractClient: Constructor.
AbstractWorker - Class in net.greghaines.jesque.worker: AbstractWorker extracts common behavior for the concrete worker implementations.
AbstractWorker(Config, Collection, JobFactory, NextQueueStrategy, ExceptionHandler) - Constructor for class net.greghaines.jesque.worker.AbstractWorker
acquireLock(String, String, Duration) - Method in class net.greghaines.jesque.client.AbstractClient: Acquire a non-blocking distributed lock.
acquireLock(String, String, Duration) - 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) - 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) - Method in class net.greghaines.jesque.worker.WorkerListenerDelegate: 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, WorkerEvent...) - Method in class net.greghaines.jesque.worker.WorkerListenerDelegate: Register a WorkerListener for the specified WorkerEvents.
addQueue(String) - Method in class net.greghaines.jesque.worker.AbstractWorker
addQueue(String) - Method in interface net.greghaines.jesque.worker.Worker: 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.
AdminClientPoolImpl - Class in net.greghaines.jesque.admin: AdminClientPoolImpl publishes jobs to channels using a connection pool.
AdminClientPoolImpl(Config, UnifiedJedis) - 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, JobFactory) - Constructor for class net.greghaines.jesque.admin.AdminImpl: Create a new AdminImpl which creates a new Jedis connection.
AdminImpl(Config, Set, 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, Set, JobFactory, UnifiedJedis) - Constructor for class net.greghaines.jesque.admin.AdminPoolImpl: Create a new AdminImpl.
AdminPoolImpl(Config, UnifiedJedis) - 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.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 Class in net.greghaines.jesque.utils: Thrown when there is more than one matching Constructor is found.
AmbiguousConstructorException(Class, Object[], Set) - Constructor for exception class net.greghaines.jesque.utils.AmbiguousConstructorException: Create a new AmbiguousConstructorException with the possible Constructor options.
AmbiguousConstructorException(String) - Constructor for exception class net.greghaines.jesque.utils.AmbiguousConstructorException: Create a new AmbiguousConstructorException with only a message.
ARRAY_SUFFIX - Static variable in class net.greghaines.jesque.utils.ReflectionUtils: Suffix for array class names: "[]"

B

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

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(JedisCommands, 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(JedisCommands, String, String) - Static method in class net.greghaines.jesque.utils.JedisUtils
CHANNEL - Static variable in interface net.greghaines.jesque.utils.ResqueConstants
checkChannels(Iterable) - Static method in class net.greghaines.jesque.admin.AdminImpl: Verify that the given channels are all valid.
checkChannels(Iterable) - 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) - Method in class net.greghaines.jesque.worker.MapBasedJobFactory: Verify the given job types are all valid.
checkQueues(Iterable) - Static method in class net.greghaines.jesque.worker.AbstractWorker: 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, UnifiedJedis) - 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) - 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 - Variable in class net.greghaines.jesque.worker.AbstractWorker
Config - Class in net.greghaines.jesque: An immutable configuration bean for use with the rest of the project.
Config.Builder - Class in net.greghaines.jesque: A fluent-style builder for Configs.
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, ConnectionPoolConfig) - 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, Iterable) - Static method in class net.greghaines.jesque.utils.JesqueUtils: Builds a namespaced Redis key with the given arguments.
createKey(String, 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.AbstractWorker: Creates a unique name, suitable for use with Resque.
createObject(Class, 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, Object[], Map) - 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
createTransaction() - Method in class net.greghaines.jesque.worker.AbstractWorker
createTransaction() - Method in class net.greghaines.jesque.worker.WorkerImpl
createTransaction() - Method in class net.greghaines.jesque.worker.WorkerPoolImpl
createWorker(String, UnifiedJedis) - 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_HOST - Static variable in class net.greghaines.jesque.Config.Builder: localhost
DEFAULT_NAMESPACE - Static variable in class net.greghaines.jesque.Config.Builder: All Resque clients use "resque" by default
DEFAULT_PORT - Static variable in class net.greghaines.jesque.Config.Builder: Default Redis port is 6379
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, Instant) - Method in class net.greghaines.jesque.client.AbstractClient: Queues a job in a given queue to be run in the future.
delayedEnqueue(String, Job, Instant) - 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, Duration) - Method in class net.greghaines.jesque.client.AbstractClient: Actually acquire the lock based upon the client acquisition model.
doAcquireLock(String, String, Duration) - Method in class net.greghaines.jesque.client.ClientImpl: Actually acquire the lock based upon the client acquisition model.
doAcquireLock(String, String, Duration) - Method in class net.greghaines.jesque.client.ClientPoolImpl: Actually acquire the lock based upon the client acquisition model.
doAcquireLock(JedisCommands, String, String, String, Duration) - Static method in class net.greghaines.jesque.client.AbstractClient: Helper method that encapsulates the logic to acquire a lock.
doBatchEnqueue(String, List) - Method in class net.greghaines.jesque.client.AbstractClient: Actually enqueue the serialized jobs.
doBatchEnqueue(String, List) - Method in class net.greghaines.jesque.client.ClientImpl: Actually enqueue the serialized jobs.
doBatchEnqueue(String, List) - Method in class net.greghaines.jesque.client.ClientPoolImpl
doBatchEnqueue(JedisCommands, Supplier, String, String, List) - Static method in class net.greghaines.jesque.client.AbstractClient: Helper method that encapsulates the minimum logic for adding jobs to a queue.
doDelayedEnqueue(String, String, Instant) - Method in class net.greghaines.jesque.client.AbstractClient
doDelayedEnqueue(String, String, Instant) - Method in class net.greghaines.jesque.client.ClientImpl
doDelayedEnqueue(String, String, Instant) - Method in class net.greghaines.jesque.client.ClientPoolImpl
doDelayedEnqueue(JedisCommands, String, String, String, Instant) - Static method in class net.greghaines.jesque.client.AbstractClient
doEnqueue(String, String) - Method in class net.greghaines.jesque.client.AbstractClient: Actually enqueue the serialized job.
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.
doEnqueue(JedisCommands, 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.
doPriorityEnqueue(String, String) - Method in class net.greghaines.jesque.client.AbstractClient: Actually enqueue the serialized job with high priority.
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.
doPriorityEnqueue(JedisCommands, 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.
doPublish(String, String) - Method in class net.greghaines.jesque.admin.AbstractAdminClient: Actually publish the serialized job.
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.
doPublish(AbstractAdminClient.Publisher, 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.
doRecurringEnqueue(String, String, Instant, Duration) - Method in class net.greghaines.jesque.client.AbstractClient
doRecurringEnqueue(String, String, Instant, Duration) - Method in class net.greghaines.jesque.client.ClientImpl
doRecurringEnqueue(String, String, Instant, Duration) - Method in class net.greghaines.jesque.client.ClientPoolImpl
doRecurringEnqueue(JedisCommands, Supplier, String, String, String, Instant, Duration) - 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
doRemoveDelayedEnqueue(JedisCommands, 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
doRemoveRecurringEnqueue(JedisCommands, Supplier, String, String, String) - Static method in class net.greghaines.jesque.client.AbstractClient
doWork(UnifiedJedis) - Method in class net.greghaines.jesque.meta.dao.impl.KeysDAORedisImpl.KeyDAOWork
DRAIN_WHILE_MESSAGES_EXISTS - Enum constant in enum class net.greghaines.jesque.worker.NextQueueStrategy: Drains messages as long as current queue is not empty

E

EMPTY_QUEUE_SLEEP_TIME - Static variable in class net.greghaines.jesque.worker.AbstractWorker
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() - 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 class net.greghaines.jesque.admin.AdminImpl: Shutdown this JobExecutor.
end(boolean) - Method in class net.greghaines.jesque.admin.AdminPoolImpl: Shutdown this JobExecutor.
end(boolean) - Method in class net.greghaines.jesque.worker.AbstractWorker: Shutdown this Worker.
The worker cannot be started again; create a new worker in this case.
end(boolean) - Method in interface net.greghaines.jesque.worker.JobExecutor: Shutdown this JobExecutor.
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(JedisCommands, 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.
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.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.
exceptionHandlerRef - Variable in class net.greghaines.jesque.worker.AbstractWorker
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.AbstractWorker: 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.AbstractWorker: Create and serialize a JobFailure.
FailQueueStrategy - Interface in net.greghaines.jesque.worker: FailQueueStrategy allows for configurable failure queues.
failQueueStrategyRef - Variable in class net.greghaines.jesque.worker.AbstractWorker
failure(Throwable, Job, String) - Method in class net.greghaines.jesque.worker.AbstractWorker: Update the status in Redis on failure.
failure(Throwable, Job, String) - Method in class net.greghaines.jesque.worker.WorkerImpl
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, UnifiedJedis) - 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."
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 class net.greghaines.jesque.utils.AmbiguousConstructorException
getArgs() - Method in exception class 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
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.Config
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 class net.greghaines.jesque.worker.AbstractWorker
getExceptionHandler() - Method in interface net.greghaines.jesque.worker.JobExecutor: 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
getFailQueueJobCount() - Method in interface net.greghaines.jesque.meta.dao.FailureDAO
getFailQueueJobCount() - Method in class net.greghaines.jesque.meta.dao.impl.FailureDAORedisImpl
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.AbstractWorker
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.meta.WorkerInfo
getHostAndPort() - Method in class net.greghaines.jesque.Config
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.
getJedis() - Method in class net.greghaines.jesque.worker.AbstractWorker
getJedis() - Method in class net.greghaines.jesque.worker.WorkerImpl
getJedis() - Method in class net.greghaines.jesque.worker.WorkerPoolImpl
getJedisClientConfig() - Method in class net.greghaines.jesque.Config
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 class net.greghaines.jesque.worker.AbstractWorker
getJobFactory() - Method in interface net.greghaines.jesque.worker.JobExecutor: 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) - Method in interface net.greghaines.jesque.meta.dao.KeysDAO: 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, 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 class 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 class net.greghaines.jesque.worker.AbstractWorker
getName() - Method in interface net.greghaines.jesque.worker.Worker: 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
getNextQueue() - Method in class net.greghaines.jesque.worker.AbstractWorker
getOptions() - Method in exception class net.greghaines.jesque.utils.AmbiguousConstructorException
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
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 class net.greghaines.jesque.worker.AbstractWorker
getQueues() - Method in interface net.greghaines.jesque.worker.Worker: 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.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
getType() - Method in class net.greghaines.jesque.meta.KeyInfo
getType() - Method in exception class net.greghaines.jesque.utils.AmbiguousConstructorException
getType() - Method in exception class net.greghaines.jesque.utils.NoSuchConstructorException
getType() - Method in exception class 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 class net.greghaines.jesque.worker.AbstractWorker
getWorkerEventEmitter() - Method in interface net.greghaines.jesque.worker.Worker
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.AbstractWorker

H

handleHash(UnifiedJedis) - Method in class net.greghaines.jesque.meta.dao.impl.KeysDAORedisImpl.KeyDAOWork
handleList(UnifiedJedis) - Method in class net.greghaines.jesque.meta.dao.impl.KeysDAORedisImpl.KeyDAOWork
handleSet(UnifiedJedis) - Method in class net.greghaines.jesque.meta.dao.impl.KeysDAORedisImpl.KeyDAOWork
handleString(UnifiedJedis) - Method in class net.greghaines.jesque.meta.dao.impl.KeysDAORedisImpl.KeyDAOWork
handleZSet(UnifiedJedis) - Method in class net.greghaines.jesque.meta.dao.impl.KeysDAORedisImpl.KeyDAOWork
HASH - Enum constant in enum class net.greghaines.jesque.meta.KeyType
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

IDLE - Enum constant in enum class net.greghaines.jesque.meta.WorkerInfo.State
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) - 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(JedisCommands, 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(JedisCommands, String) - Static method in class net.greghaines.jesque.utils.JedisUtils: Determines if the queue identified by the given key is used.
isPaused() - Method in class net.greghaines.jesque.worker.AbstractWorker
isPaused() - Method in interface net.greghaines.jesque.worker.Worker: 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 class net.greghaines.jesque.admin.AdminPoolImpl: Returns whether this JobExecutor is currently processing a job.
isProcessingJob() - Method in class net.greghaines.jesque.worker.AbstractWorker
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.WorkerPool: Returns whether this JobExecutor is currently processing a job.
isRecurringQueue(JedisCommands, 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 class net.greghaines.jesque.worker.AbstractWorker
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.WorkerPool: Returns whether this JobExecutor is either shutdown or in the process of shutting down.
isThreadNameChangingEnabled() - Static method in class net.greghaines.jesque.worker.AbstractWorker
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, UnifiedJedis) - 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(String, Object...) - Constructor for class net.greghaines.jesque.Job: Create a new Job with the given class name and arguments.
Job(String, Object[], Map) - 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.
Job(String, List) - Constructor for class net.greghaines.jesque.Job: A convenience constructor.
Job(String, Map) - 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(Job) - Constructor for class net.greghaines.jesque.Job: Cloning constructor.
JOB_EXECUTE - Enum constant in enum class net.greghaines.jesque.worker.WorkerEvent: The Worker is about to execute a materialized Job.
JOB_FAILURE - Enum constant in enum class net.greghaines.jesque.worker.WorkerEvent: The Worker caught an Exception during the execution of a materialized Job.
JOB_PROCESS - Enum constant in enum class net.greghaines.jesque.worker.WorkerEvent: The Worker is processing a Job.
JOB_SUCCESS - Enum constant in enum class net.greghaines.jesque.worker.WorkerEvent: The Worker successfully executed a materialized Job.
JobExecutor - Interface in net.greghaines.jesque.worker: JobExecutor is an object that executes jobs.
JobExecutor.State - Enum Class in net.greghaines.jesque.worker: States of the job executor.
jobFactory - Variable in class net.greghaines.jesque.worker.AbstractWorker
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(long) - Method in class net.greghaines.jesque.worker.AbstractWorker
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.WorkerPool: Join to internal threads and wait millis time per thread or until all threads are finished if millis is 0.
join(String, Iterable) - Static method in class net.greghaines.jesque.utils.JesqueUtils: Join the given strings, separated by the given separator.
join(String, String...) - Static method in class net.greghaines.jesque.utils.JesqueUtils: Join the given strings, separated by the given separator.

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.AbstractWorker: Builds a namespaced Redis key with the given arguments.
KeyDAOWork(String) - Constructor for class net.greghaines.jesque.meta.dao.impl.KeysDAORedisImpl.KeyDAOWork
KeyDAOWork(String, int, int) - Constructor for class net.greghaines.jesque.meta.dao.impl.KeysDAORedisImpl.KeyDAOWork
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, UnifiedJedis) - Constructor for class net.greghaines.jesque.meta.dao.impl.KeysDAORedisImpl: Constructor.
KeysDAORedisImpl.KeyDAOWork - Class in net.greghaines.jesque.meta.dao.impl
KeyType - Enum Class in net.greghaines.jesque.meta: KeyTypes are the types of Redis keys that Jesque uses.

L

LIST - Enum constant in enum class net.greghaines.jesque.meta.KeyType
listenerDelegate - Variable in class net.greghaines.jesque.worker.AbstractWorker
loadRedisScript(String) - Method in class net.greghaines.jesque.worker.AbstractWorker
loadRedisScript(String) - Method in class net.greghaines.jesque.worker.WorkerImpl
loadRedisScript(String) - Method in class net.greghaines.jesque.worker.WorkerPoolImpl
loadRedisScripts() - Method in class net.greghaines.jesque.worker.AbstractWorker
loadRedisScripts() - Method in class net.greghaines.jesque.worker.WorkerPoolImpl
LOG - Static variable in class net.greghaines.jesque.worker.AbstractWorker
LoggingWorkerListener - Class in net.greghaines.jesque.worker: LoggingWorkerListener logs every event that it is registered for.
LPOPLPUSH_LUA - Static variable in class net.greghaines.jesque.worker.AbstractWorker
lpoplpushScriptHash - Variable in class net.greghaines.jesque.worker.AbstractWorker

M

MapBasedJobFactory - Class in net.greghaines.jesque.worker: MapBasedJobFactory uses a map of job names and types to materialize jobs.
MapBasedJobFactory(Map) - 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) - 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.
materializeJob(Job, Map) - Static method in class net.greghaines.jesque.utils.JesqueUtils: Materializes a job by looking up Job.getClassName() in the provided map of job types.
multiPriorityQueuesScriptHash - Variable in class net.greghaines.jesque.worker.AbstractWorker

N

name - Variable in class net.greghaines.jesque.worker.AbstractWorker
namespace - Variable in class net.greghaines.jesque.admin.AdminImpl
namespace - Variable in class net.greghaines.jesque.admin.AdminPoolImpl
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
NEW - Enum constant in enum class net.greghaines.jesque.worker.JobExecutor.State: The JobExecutor has not started running.
newBuilder() - Static method in class net.greghaines.jesque.Config
nextQueueStrategy - Variable in class net.greghaines.jesque.worker.AbstractWorker
NextQueueStrategy - Enum Class in net.greghaines.jesque.worker: Strategies to determine the next queue a Worker will poll.
NONE - Enum constant in enum class net.greghaines.jesque.meta.KeyType
NoSuchConstructorException - Exception Class in net.greghaines.jesque.utils: Thrown when the specified constructor could not be found.
NoSuchConstructorException(Class, Object...) - Constructor for exception class net.greghaines.jesque.utils.NoSuchConstructorException: Create a new NoSuchConstructorException with the type and arguments.
NoSuchConstructorException(String) - Constructor for exception class net.greghaines.jesque.utils.NoSuchConstructorException: Create a new NoSuchConstructorException with only a message.

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.
paused - Variable in class net.greghaines.jesque.worker.AbstractWorker
PAUSED - Enum constant in enum class net.greghaines.jesque.meta.WorkerInfo.State
poll() - Method in class net.greghaines.jesque.worker.AbstractWorker
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.
pop(String) - Method in class net.greghaines.jesque.worker.AbstractWorker: Remove a job from the given queue.
POP_FROM_MULTIPLE_PRIO_QUEUES - Static variable in class net.greghaines.jesque.worker.AbstractWorker
POP_LUA - Static variable in class net.greghaines.jesque.worker.AbstractWorker
popScriptHash - Variable in class net.greghaines.jesque.worker.AbstractWorker
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.
PROCEED - Enum constant in enum class net.greghaines.jesque.worker.RecoveryStrategy: Worker should ignore the error and proceed.
process(Job, String) - Method in class net.greghaines.jesque.worker.AbstractWorker: Materializes and executes the given job.
PROCESSED - Static variable in interface net.greghaines.jesque.utils.ResqueConstants
processingJob - Variable in class net.greghaines.jesque.worker.AbstractWorker
publish(String, String) - Method in interface net.greghaines.jesque.admin.AbstractAdminClient.Publisher
publish(String, Job) - Method in class net.greghaines.jesque.admin.AbstractAdminClient: Publishes a job on the given channel.
publish(String, Job) - Method in interface net.greghaines.jesque.admin.AdminClient: Publishes a job on the given channel.
publish(Job) - Method in class net.greghaines.jesque.admin.AbstractAdminClient: Publishes a job on the ResqueConstants.ADMIN_CHANNEL channel.
publish(Job) - Method in interface net.greghaines.jesque.admin.AdminClient: Publishes a job on the ResqueConstants.ADMIN_CHANNEL 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, UnifiedJedis) - Constructor for class net.greghaines.jesque.meta.dao.impl.QueueInfoDAORedisImpl: Constructor.
queueNames - Variable in class net.greghaines.jesque.worker.AbstractWorker
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 - Enum constant in enum class net.greghaines.jesque.worker.RecoveryStrategy: Worker should attempt to reconnect to Redis.
RECONNECT_SLEEP_TIME - Static variable in class net.greghaines.jesque.worker.AbstractWorker
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.AbstractWorker: Handle an exception that was thrown from inside AbstractWorker.poll().
recoverFromException(String, Exception) - Method in class net.greghaines.jesque.worker.WorkerImpl: Handle an exception that was thrown from inside AbstractWorker.poll().
recoverFromException(String, Exception) - Method in class net.greghaines.jesque.worker.WorkerPoolImpl
RecoveryStrategy - Enum Class in net.greghaines.jesque.worker: RecoveryStrategy are the possible means for a worker to recover from an error.
recreateStackTrace(List) - Static method in class net.greghaines.jesque.utils.JesqueUtils
recreateThrowable(String, String, List) - 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, Instant, Duration) - Method in class net.greghaines.jesque.client.AbstractClient: Queues a job to be in the future and recur
recurringEnqueue(String, Job, Instant, Duration) - 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
registerWorker() - Method in class net.greghaines.jesque.worker.AbstractWorker
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() - Method in class net.greghaines.jesque.worker.WorkerListenerDelegate: Unregister all WorkerListeners for all WorkerEvents.
removeAllListeners(WorkerEvent...) - Method in interface net.greghaines.jesque.worker.WorkerEventEmitter: Unregister all WorkerListeners for the specified WorkerEvents.
removeAllListeners(WorkerEvent...) - Method in class net.greghaines.jesque.worker.WorkerListenerDelegate: Unregister all WorkerListeners for the specified WorkerEvents.
removeAllQueues() - Method in class net.greghaines.jesque.worker.AbstractWorker
removeAllQueues() - Method in interface net.greghaines.jesque.worker.Worker: 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.
removeInFlight(String, boolean) - Method in class net.greghaines.jesque.worker.AbstractWorker
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) - Method in class net.greghaines.jesque.worker.WorkerListenerDelegate: 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, 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 class net.greghaines.jesque.worker.AbstractWorker
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.WorkerPool: 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.AbstractWorker: 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.
RESET_TO_HIGHEST_PRIORITY - Enum constant in enum class net.greghaines.jesque.worker.NextQueueStrategy: Resets to check the first queue, then second queue, etc. after each message is processed.
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.AbstractWorker: Starts this worker.
run() - Method in class net.greghaines.jesque.worker.WorkerPool
RUNNING - Enum constant in enum class net.greghaines.jesque.worker.JobExecutor.State: The JobExecutor is currently running.

S

ScriptUtils - Class in net.greghaines.jesque.utils: ScriptUtils contains utility methods for executing Lua scripts in Redis.
SET - Enum constant in enum class net.greghaines.jesque.meta.KeyType
setArgs(Object...) - Method in class net.greghaines.jesque.Job: Set the arguments.
setArrayValue(List) - Method in class net.greghaines.jesque.meta.KeyInfo
setBacktrace(List) - Method in class net.greghaines.jesque.JobFailure: Set the backtrace of the throwable
setChannels(Set) - Method in interface net.greghaines.jesque.admin.Admin
setChannels(Set) - Method in class net.greghaines.jesque.admin.AdminImpl
setChannels(Set) - 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 class net.greghaines.jesque.worker.AbstractWorker
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.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.
setFailQueueStrategy(FailQueueStrategy) - Method in class net.greghaines.jesque.worker.AbstractWorker
setHost(String) - Method in class net.greghaines.jesque.meta.WorkerInfo
setJobs(List) - Method in class net.greghaines.jesque.meta.QueueInfo
setJobTypes(Map) - 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(Collection) - Method in class net.greghaines.jesque.worker.AbstractWorker
setQueues(Collection) - 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) - 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(List) - Method in class net.greghaines.jesque.meta.WorkerInfo
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.AbstractWorker: Enable/disable worker thread renaming during normal operation.
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) - Method in class net.greghaines.jesque.Job: Set all unknown fields
setVars(Map) - Method in class net.greghaines.jesque.Job: Set the named arguments.
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.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(Worker) - Method in interface net.greghaines.jesque.worker.WorkerAware
shouldSleep(int) - Method in class net.greghaines.jesque.worker.AbstractWorker
SHUTDOWN - Enum constant in enum class net.greghaines.jesque.worker.JobExecutor.State: The JobExecutor has shutdown.
SHUTDOWN_IMMEDIATE - Enum constant in enum class net.greghaines.jesque.worker.JobExecutor.State: The JobExecutor has shutdown, interrupting running jobs.
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(boolean) - Method in interface net.greghaines.jesque.admin.AdminClient: 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(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.AbstractWorker
STRING - Enum constant in enum class net.greghaines.jesque.meta.KeyType
success(Job, Object, Object, String) - Method in class net.greghaines.jesque.worker.AbstractWorker: Update the status in Redis on success.
success(Job, Object, Object, String) - Method in class net.greghaines.jesque.worker.WorkerImpl

T

TERMINATE - Enum constant in enum class net.greghaines.jesque.worker.RecoveryStrategy: Worker should terminate.
testJedisConnection(Jedis) - Static method in class net.greghaines.jesque.utils.JedisUtils: Test if a connection is valid.
threadNameBase - Variable in class net.greghaines.jesque.worker.AbstractWorker
threadNameChangingEnabled - Static variable in class net.greghaines.jesque.worker.AbstractWorker
threadRef - Variable in class net.greghaines.jesque.worker.AbstractWorker
toArray() - Method in class net.greghaines.jesque.utils.ConcurrentHashSet
toArray(T[]) - Method in class net.greghaines.jesque.utils.ConcurrentHashSet
toBuilder() - Method in class net.greghaines.jesque.Config
togglePause(boolean) - Method in class net.greghaines.jesque.worker.AbstractWorker
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.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(boolean) - Method in interface net.greghaines.jesque.admin.AdminClient: 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(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 class 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.AbstractWorker
toString() - Method in class net.greghaines.jesque.WorkerStatus

U

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

V

valueOf(String) - Static method in enum class net.greghaines.jesque.meta.KeyType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class net.greghaines.jesque.meta.WorkerInfo.State: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class net.greghaines.jesque.worker.JobExecutor.State: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class net.greghaines.jesque.worker.NextQueueStrategy: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class net.greghaines.jesque.worker.RecoveryStrategy: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class net.greghaines.jesque.worker.WorkerEvent: Returns the enum constant of this class with the specified name.
values() - Static method in enum class net.greghaines.jesque.meta.KeyType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class net.greghaines.jesque.meta.WorkerInfo.State: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class net.greghaines.jesque.worker.JobExecutor.State: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class net.greghaines.jesque.worker.NextQueueStrategy: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class net.greghaines.jesque.worker.RecoveryStrategy: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class net.greghaines.jesque.worker.WorkerEvent: Returns an array containing the constants of this enum class, 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.Config.Builder: Configs created by this Builder will use the given Redis database.
withHostAndPort(String, int) - Method in class net.greghaines.jesque.Config.Builder: Configs created by this Builder will connect to the specified hostname and port.
withJedisClientConfig(JedisClientConfig) - Method in class net.greghaines.jesque.Config.Builder: Configs created by this Builder will use the JedisClientConfig.
withMasterNameAndSentinels(String, Set) - Method in class net.greghaines.jesque.Config.Builder: Configs created by this Builder will connect to the specified master name and sentinels.
withNamespace(String) - Method in class net.greghaines.jesque.Config.Builder: Configs created by this Builder will have the given Redis namespace to prefix keys with.
withPassword(String) - Method in class net.greghaines.jesque.Config.Builder: Configs created by this Builder will authenticate with the given Redis password.
withTimeout(int) - Method in class net.greghaines.jesque.Config.Builder: Configs created by this Builder will have the given Redis connection timeout.
withUser(String) - Method in class net.greghaines.jesque.Config.Builder: Configs created by this Builder will authenticate with the given Redis user.
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.
WORKER - Static variable in interface net.greghaines.jesque.utils.ResqueConstants
WORKER_COUNTER - Static variable in class net.greghaines.jesque.worker.AbstractWorker
WORKER_ERROR - Enum constant in enum class net.greghaines.jesque.worker.WorkerEvent: The Worker caught an Exception during normal operation.
WORKER_POLL - Enum constant in enum class net.greghaines.jesque.worker.WorkerEvent: The Worker is polling the queue.
WORKER_START - Enum constant in enum class net.greghaines.jesque.worker.WorkerEvent: The Worker just finished starting up and is about to start running.
WORKER_STOP - Enum constant in enum class net.greghaines.jesque.worker.WorkerEvent: The Worker just finished running and is about to shutdown.
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 Class 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.
workerId - Variable in class net.greghaines.jesque.worker.AbstractWorker
WorkerImpl - Class in net.greghaines.jesque.worker: WorkerImpl is an implementation of the Worker interface.
WorkerImpl(Config, Collection, 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, 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, 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, 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 Class 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, UnifiedJedis) - 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, int) - Constructor for class net.greghaines.jesque.worker.WorkerPool: Create a WorkerPool with the given number of Workers and the default ThreadFactory .
WorkerPool(Callable, 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, JobFactory, UnifiedJedis) - 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, JobFactory, UnifiedJedis, 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, JobFactory, UnifiedJedis) - 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.
WORKING - Enum constant in enum class net.greghaines.jesque.meta.WorkerInfo.State

Z

ZSET - Enum constant in enum class net.greghaines.jesque.meta.KeyType

A B C D E F G H I J K L M N O P Q R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form