net.greghaines.jesque.worker

Class DefaultPoolExceptionHandler

java.lang.Object

net.greghaines.jesque.worker.DefaultPoolExceptionHandler

All Implemented Interfaces:

ExceptionHandler

public class DefaultPoolExceptionHandler
extends Object
implements ExceptionHandler

DefaultPoolExceptionHandler reconnects if there is a connection exception, proceeds if the exception was JSON-related or a thread interrupt and terminates if the executor is shutdown.

Constructor Summary

Constructors

Constructor and Description
DefaultPoolExceptionHandler()

Method Summary

Modifier and Type	Method and Description
RecoveryStrategy	onException(JobExecutor jobExecutor, Exception exception, String curQueue) Called when a worker encounters an exception.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultPoolExceptionHandler

public DefaultPoolExceptionHandler()

Method Detail

onException

public RecoveryStrategy onException(JobExecutor jobExecutor,
                                    Exception exception,
                                    String curQueue)

Called when a worker encounters an exception.

Specified by:

onException in interface ExceptionHandler

Parameters:

jobExecutor - the worker that encountered the exception

exception - the exception

curQueue - the current queue being processed

Returns:

the RecoveryStrategy to use