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

An implementation of WorkerListener that logs every event that it is registered for.

Author:

Greg Haines

Field Summary

Fields

Modifier and Type	Field and Description
static LoggingWorkerListener	INSTANCE

Method Summary

Methods

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

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)

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 occured

worker - the Worker that the event occured 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)