net.greghaines.jesque.worker

Class WorkerListenerDelegate

java.lang.Object

net.greghaines.jesque.worker.WorkerListenerDelegate

All Implemented Interfaces:

WorkerEventEmitter

public class WorkerListenerDelegate
extends Object
implements WorkerEventEmitter

This class keeps track of WorkerListeners and notifies each listener when fireEvent() is invoked.

Author:

Greg Haines

Constructor Summary

Constructors

Constructor and Description
WorkerListenerDelegate() Create a new WorkerListenerDelegate.

Method Summary

Modifier and Type	Method and Description
void	addListener(WorkerListener listener) Register a WorkerListener for all WorkerEvents.
void	addListener(WorkerListener listener, WorkerEvent... events) Register a WorkerListener for the specified WorkerEvents.
void	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	removeAllListeners() Unregister all WorkerListeners for all WorkerEvents.
void	removeAllListeners(WorkerEvent... events) Unregister all WorkerListeners for the specified WorkerEvents.
void	removeListener(WorkerListener listener) Unregister a WorkerListener for all WorkerEvents.
void	removeListener(WorkerListener listener, WorkerEvent... events) Unregister a WorkerListener for the specified WorkerEvents.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WorkerListenerDelegate

public WorkerListenerDelegate()

Create a new WorkerListenerDelegate.

Method Detail

addListener

public void addListener(WorkerListener listener)

Register a WorkerListener for all WorkerEvents.

Specified by:

addListener in interface WorkerEventEmitter

Parameters:

listener - the WorkerListener to register

addListener

public void addListener(WorkerListener listener,
                        WorkerEvent... events)

Register a WorkerListener for the specified WorkerEvents.

Specified by:

addListener in interface WorkerEventEmitter

Parameters:

listener - the WorkerListener to register

events - the WorkerEvents to be notified of

removeListener

public void removeListener(WorkerListener listener)

Unregister a WorkerListener for all WorkerEvents.

Specified by:

removeListener in interface WorkerEventEmitter

Parameters:

listener - the WorkerListener to unregister

removeListener

public void removeListener(WorkerListener listener,
                           WorkerEvent... events)

Unregister a WorkerListener for the specified WorkerEvents.

Specified by:

removeListener in interface WorkerEventEmitter

Parameters:

listener - the WorkerListener to unregister

events - the WorkerEvents to no longer be notified of

removeAllListeners

public void removeAllListeners()

Unregister all WorkerListeners for all WorkerEvents.

Specified by:

removeAllListeners in interface WorkerEventEmitter

removeAllListeners

public void removeAllListeners(WorkerEvent... events)

Unregister all WorkerListeners for the specified WorkerEvents.

Specified by:

removeAllListeners in interface WorkerEventEmitter

Parameters:

events - the WorkerEvents to no longer be notified of

fireEvent

public void fireEvent(WorkerEvent event,
                      Worker worker,
                      String queue,
                      Job job,
                      Object runner,
                      Object result,
                      Throwable t)

Notify all WorkerListeners currently registered for the given WorkerEvent.

Parameters:

event - the WorkerEvent that occurred

worker - the Worker that the event occurred in

queue - the queue the Worker is processing

job - the Job related to the event (only supply for JOB_PROCESS, JOB_EXECUTE, JOB_SUCCESS, and JOB_FAILURE events)

runner - the materialized object that the Job specified (only supply for JOB_EXECUTE and JOB_SUCCESS events)

result - the result of the successful execution of the Job (only set for JOB_SUCCESS and if the Job was a Callable that returned a value)

t - the Throwable that caused the event (only supply for JOB_FAILURE and ERROR events)