| Package | Description |
|---|---|
| net.greghaines.jesque.admin | |
| net.greghaines.jesque.admin.commands | |
| net.greghaines.jesque.worker |
| Modifier and Type | Field and Description |
|---|---|
protected AtomicReference<Worker> |
AdminImpl.workerRef |
| Modifier and Type | Method and Description |
|---|---|
Worker |
AdminImpl.getWorker() |
Worker |
Admin.getWorker() |
| Modifier and Type | Method and Description |
|---|---|
void |
AdminImpl.setWorker(Worker worker) |
void |
Admin.setWorker(Worker worker) |
| Modifier and Type | Method and Description |
|---|---|
void |
PauseCommand.setWorker(Worker worker) |
void |
ShutdownCommand.setWorker(Worker worker) |
| Modifier and Type | Class and Description |
|---|---|
class |
WorkerImpl
Basic implementation of the Worker interface.
|
class |
WorkerPool
Creates a fixed number of identical
Workers, each on a separate
Thread. |
| Modifier and Type | Method and Description |
|---|---|
void |
WorkerListenerDelegate.fireEvent(WorkerEvent event,
Worker worker,
String queue,
Job job,
Object runner,
Object result,
Throwable t)
Notify all WorkerListeners currently registered for the given WorkerEvent.
|
void |
WorkerListener.onEvent(WorkerEvent event,
Worker worker,
String queue,
Job job,
Object runner,
Object result,
Throwable t)
This method is called by the Worker upon the occurence of a registered
WorkerEvent.
|
void |
LoggingWorkerListener.onEvent(WorkerEvent event,
Worker worker,
String queue,
Job job,
Object runner,
Object result,
Throwable t)
If there is a Throwable, it is logged as an error, otherwise it is
logged as a debug message.
|
void |
WorkerAware.setWorker(Worker worker) |
| Constructor and Description |
|---|
WorkerPool(Callable<? extends Worker> workerFactory,
int numWorkers)
Create a WorkerPool with the given number of Workers and the default
ThreadFactory. |
WorkerPool(Callable<? extends Worker> workerFactory,
int numWorkers,
ThreadFactory threadFactory)
Create a WorkerPool with the given number of Workers and the given
ThreadFactory. |
Copyright © 2011-2015. All Rights Reserved.