net.greghaines.jesque.worker

Class LoggingWorkerListener

java.lang.Object

net.greghaines.jesque.worker.LoggingWorkerListener

All Implemented Interfaces:

WorkerListener

public class LoggingWorkerListener
extends Object
implements WorkerListener

LoggingWorkerListener logs every event that it is registered for.

Field Summary

Fields

Modifier and Type	Field and Description
static LoggingWorkerListener	INSTANCE

Method Summary

Modifier and Type	Method and Description
void	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.

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final LoggingWorkerListener INSTANCE

Method Detail

onEvent

public void 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. If there is a Throwable, it is logged as an error, otherwise it is logged as a debug message.

Specified by:

onEvent in interface WorkerListener

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 set for JOB_PROCESS, JOB_EXECUTE, JOB_SUCCESS, and JOB_FAILURE events)

runner - the materialized object that the Job specified (only set 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 set for JOB_FAILURE and ERROR events)