Package io.camunda.client.impl.worker

Class JobExceptionHandlerImpl

java.lang.Object

io.camunda.client.impl.worker.JobExceptionHandlerImpl

All Implemented Interfaces:

JobExceptionHandler

public class JobExceptionHandlerImpl
extends Object
implements JobExceptionHandler

Nested Class Summary

Nested classes/interfaces inherited from interface io.camunda.client.api.worker.JobExceptionHandler

JobExceptionHandler.JobExceptionHandlerContext

Field Summary

Fields

Modifier and Type	Field	Description
static final Function<JobExceptionHandler.JobExceptionHandlerContext,String>	DEFAULT_ERROR_MESSAGE_PROVIDER
static final BiConsumer<FailJobCommandStep1.FailJobCommandStep2,JobExceptionHandler.JobExceptionHandlerContext>	DEFAULT_FAIL_COMMAND_EXECUTOR
static final Function<JobExceptionHandler.JobExceptionHandlerContext,Integer>	DEFAULT_RETRIES_PROVIDER
static final Function<JobExceptionHandler.JobExceptionHandlerContext,Duration>	DEFAULT_RETRY_BACKOFF_PROVIDER
static final Function<JobExceptionHandler.JobExceptionHandlerContext,Object>	DEFAULT_VARIABLES_PROVIDER

Constructor Summary

Constructors

Constructor	Description
JobExceptionHandlerImpl()
JobExceptionHandlerImpl(Duration retryBackoff)
JobExceptionHandlerImpl(Function<JobExceptionHandler.JobExceptionHandlerContext,String> errorMessageProvider, Function<JobExceptionHandler.JobExceptionHandlerContext,Integer> retriesProvider, Function<JobExceptionHandler.JobExceptionHandlerContext,Duration> retryBackoffProvider, Function<JobExceptionHandler.JobExceptionHandlerContext,Object> variablesProvider, BiConsumer<FailJobCommandStep1.FailJobCommandStep2,JobExceptionHandler.JobExceptionHandlerContext> failCommandExecutor)

Method Summary

Modifier and Type	Method	Description
void	handleJobException(JobExceptionHandler.JobExceptionHandlerContext context)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_ERROR_MESSAGE_PROVIDER

public static final Function<JobExceptionHandler.JobExceptionHandlerContext,String> DEFAULT_ERROR_MESSAGE_PROVIDER

DEFAULT_RETRIES_PROVIDER

public static final Function<JobExceptionHandler.JobExceptionHandlerContext,Integer> DEFAULT_RETRIES_PROVIDER

DEFAULT_RETRY_BACKOFF_PROVIDER

public static final Function<JobExceptionHandler.JobExceptionHandlerContext,Duration> DEFAULT_RETRY_BACKOFF_PROVIDER

DEFAULT_VARIABLES_PROVIDER

public static final Function<JobExceptionHandler.JobExceptionHandlerContext,Object> DEFAULT_VARIABLES_PROVIDER

DEFAULT_FAIL_COMMAND_EXECUTOR

public static final BiConsumer<FailJobCommandStep1.FailJobCommandStep2,JobExceptionHandler.JobExceptionHandlerContext> DEFAULT_FAIL_COMMAND_EXECUTOR

Constructor Details

JobExceptionHandlerImpl

public JobExceptionHandlerImpl(Function<JobExceptionHandler.JobExceptionHandlerContext,String> errorMessageProvider,
 Function<JobExceptionHandler.JobExceptionHandlerContext,Integer> retriesProvider,
 Function<JobExceptionHandler.JobExceptionHandlerContext,Duration> retryBackoffProvider,
 Function<JobExceptionHandler.JobExceptionHandlerContext,Object> variablesProvider,
 BiConsumer<FailJobCommandStep1.FailJobCommandStep2,JobExceptionHandler.JobExceptionHandlerContext> failCommandExecutor)

JobExceptionHandlerImpl

public JobExceptionHandlerImpl()

JobExceptionHandlerImpl

public JobExceptionHandlerImpl(Duration retryBackoff)

Method Details

handleJobException

public void handleJobException(JobExceptionHandler.JobExceptionHandlerContext context)

Specified by:

handleJobException in interface JobExceptionHandler