Package net.greghaines.jesque.worker

Interface Summary

Interface	Description
ExceptionHandler
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	An ExceptionHandler that reconnects if there is a connection exception, proceeds if the exception was JSON-related or a thread interrupt and terminates if the executor is shutdown.
LoggingWorkerListener	An implementation of WorkerListener that 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	Basic implementation of the Worker interface.
WorkerImplFactory	A simple factory for WorkerImpls.
WorkerListenerDelegate	This class 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.

Enum Summary

Enum	Description
JobExecutor.State	States of the job executor.
RecoveryStrategy	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.