All Classes and Interfaces

Class
Description
Common logic for AdminClient implementations.
 
Common logic for Client implementations.
AbstractWorker extracts common behavior for the concrete worker implementations.
Admin is an interface to receive administrative jobs for a worker.
An AdminClient publishes jobs to channels.
AdminClientImpl publishes jobs to channels.
AdminClientPoolImpl publishes jobs to channels using a connection pool.
AdminImpl receives administrative jobs for a worker.
AdminPoolImpl receives administrative jobs for a worker using a connection pool.
Thrown when there is more than one matching Constructor is found.
A Client allows Jobs to be enqueued for execution by Workers.
Basic implementation of the Client interface.
A Client implementation that gets its connection to Redis from a connection pool.
CompositeDateFormat attempts to parse dates using several known date format patterns and formats dates using ResqueDateFormatThreadLocal.getInstance().
An implementation of ConcurrentSet that is backed by a ConcurrentHashMap.
An interface that denotes the implementation of Set is thread-safe.
It adds no new methods.
An immutable configuration bean for use with the rest of the project.
A fluent-style builder for Configs.
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.
DefaultFailQueueStrategy puts all jobs in the standard Redis failure queue and imposes no limits on the max number of failed items to keep.
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.
ExceptionHandler allows for customized handling of exceptions received by a Worker.
FailQueueStrategy allows for configurable failure queues.
FailureDAO provides access to job failures.
Accesses failure information about Jesque/Resque from Redis.
A collection of utilities for Redis connections.
Miscellaneous utilities.
A simple class to describe a job to be run by a worker.
JobExecutor is an object that executes jobs.
States of the job executor.
JobFactory materializes jobs.
A bean to hold information about a job that failed.
Information about a key in Redis.
KeysDAO provides access to available keys.
KeysDAORedisImpl gets key information from Redis.
 
KeyTypes are the types of Redis keys that Jesque uses.
LoggingWorkerListener logs every event that it is registered for.
MapBasedJobFactory uses a map of job names and types to materialize jobs.
Strategies to determine the next queue a Worker will poll.
Thrown when the specified constructor could not be found.
A helper that creates a fully-configured singleton ObjectMapper.
Pause the worker that receives this job.
Convenience methods for doing work with pooled Jedis connections.
Information about the current state of a queue.
QueueInfoDAO provides access to the queues in use by Jesque.
QueueInfoDAORedisImpl gets queue information from Redis.
RecoveryStrategy are the possible means for a worker to recover from an error.
Reflection utilities.
ReflectiveJobFactory assumes job names are fully-qualified class names.
Constants used by Resque.
Provides DateFormats configured for use with Resque.
ScriptUtils contains utility methods for executing Lua scripts in Redis.
Shuts down the worker that receives this job.
Thrown by a Worker when it receives a Job that it is not allowed to run.
Grabs the version number from the Maven metadata.
A Worker polls for Jobs from a specified list of queues, executing them in sequence and notifying WorkerListeners in the process.
WorkerAware indicates that a materialized Job should have the Worker executing the job injected before execution.
The possible WorkerEvents that a WorkerListener may register for.
A WorkerEventEmitter allows WorkerListeners to register for WorkerEvents.
WorkerImpl is an implementation of the Worker interface.
WorkerImplFactory is a factory for WorkerImpls.
Information about the current state of a worker.
Possible states of a worker.
WorkerInfoDAO provides access to information about workers.
WorkerInfoDAORedisImpl gets worker information from Redis.
A WorkerListener can register with a Worker to be notified of WorkerEvents.
WorkerListenerDelegate keeps track of WorkerListeners and notifies each listener when fireEvent() is invoked.
WorkerPool creates a fixed number of identical Workers, each on a separate Thread.
WorkerPoolImpl is an implementation of the Worker interface that uses a connection pool.
WorkerPoolImplFactory is a factory for WorkerPoolImpls.
A bean to hold information about the status of a Worker.