Package net.greghaines.jesque.worker

Interface Summary

Interface	Description
ExceptionHandler	ExceptionHandler allows for customized handling of exceptions received by a Worker.
FailQueueStrategy	FailQueueStrategy allows for configurable failure queues.
JobExecutor	JobExecutor is an object that executes jobs.
JobFactory	JobFactory materializes jobs.
Worker	A Worker polls for Jobs from a specified list of queues, executing them in sequence and notifying WorkerListeners in the process.
WorkerAware	WorkerAware indicates that a materialized Job should have the Worker executing the job injected before execution.
WorkerEventEmitter	A WorkerEventEmitter allows WorkerListeners to register for WorkerEvents.
WorkerListener	A WorkerListener can register with a Worker to be notified of WorkerEvents.

Class Summary

Class	Description
DefaultExceptionHandler	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	DefaultFailQueueStrategy puts all jobs in the standard Redis failure queue and imposes no limits on the max number of failed items to keep.
DefaultPoolExceptionHandler	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.
LoggingWorkerListener	LoggingWorkerListener logs every event that it is registered for.
MapBasedJobFactory	MapBasedJobFactory uses a map of job names and types to materialize jobs.
ReflectiveJobFactory	ReflectiveJobFactory assumes job names are fully-qualified class names.
WorkerImpl	WorkerImpl is an implementation of the Worker interface.
WorkerImplFactory	WorkerImplFactory is a factory for WorkerImpls.
WorkerListenerDelegate	WorkerListenerDelegate keeps track of WorkerListeners and notifies each listener when fireEvent() is invoked.
WorkerPool	WorkerPool creates a fixed number of identical Workers, each on a separate Thread.
WorkerPoolImpl	WorkerPoolImpl is an implementation of the Worker interface that uses a connection pool.
WorkerPoolImplFactory	WorkerPoolImplFactory is a factory for WorkerPoolImpls.

Enum Summary

Enum	Description
JobExecutor.State	States of the job executor.
NextQueueStrategy	Strategies to determine the next queue a Worker will poll.
RecoveryStrategy	RecoveryStrategy are the possible means for a worker to recover from an error.
WorkerEvent	The possible WorkerEvents that a WorkerListener may register for.

Exception Summary

Exception	Description
UnpermittedJobException	Thrown by a Worker when it receives a Job that it is not allowed to run.