| 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 |
protected AtomicReference<Worker> |
AdminPoolImpl.workerRef |
| Modifier and Type | Method and Description |
|---|---|
Worker |
AdminImpl.getWorker() |
Worker |
AdminPoolImpl.getWorker() |
Worker |
Admin.getWorker() |
| Modifier and Type | Method and Description |
|---|---|
void |
AdminImpl.setWorker(Worker worker) |
void |
AdminPoolImpl.setWorker(Worker worker) |
void |
Admin.setWorker(Worker worker) |
| Modifier and Type | Method and Description |
|---|---|
void |
ShutdownCommand.setWorker(Worker worker) |
void |
PauseCommand.setWorker(Worker worker) |
| Modifier and Type | Class and Description |
|---|---|
class |
WorkerImpl
WorkerImpl is an implementation of the Worker interface.
|
class |
WorkerPool
WorkerPool creates a fixed number of identical
Workers, each on a separate Thread. |
class |
WorkerPoolImpl
WorkerPoolImpl is an implementation of the Worker interface that uses a connection pool.
|
| 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 |
LoggingWorkerListener.onEvent(WorkerEvent event,
Worker worker,
String queue,
Job job,
Object runner,
Object result,
Throwable t)
This method is called by the Worker upon the occurrence of a registered 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 occurrence of a registered WorkerEvent.
|
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–2019. All rights reserved.