org.flowable.job.service.impl

Class ExternalWorkerJobFailureBuilderImpl

java.lang.Object

org.flowable.job.service.impl.ExternalWorkerJobFailureBuilderImpl

All Implemented Interfaces:

ExternalWorkerJobFailureBuilder

public class ExternalWorkerJobFailureBuilderImpl
extends Object
implements ExternalWorkerJobFailureBuilder

Author:

Filip Hrisafov

Field Summary

Fields

Modifier and Type	Field and Description
protected CommandExecutor	commandExecutor
protected String	errorDetails
protected String	errorMessage
protected String	externalJobId
protected JobServiceConfiguration	jobServiceConfiguration
protected int	retries
protected Duration	retryTimeout
protected String	workerId

Constructor Summary

Constructors

Constructor and Description
ExternalWorkerJobFailureBuilderImpl(String externalJobId, String workerId, CommandExecutor commandExecutor, JobServiceConfiguration jobServiceConfiguration)

Method Summary

Modifier and Type	Method and Description
ExternalWorkerJobFailureBuilder	errorDetails(String errorDetails) The longer error details for the failing job.
ExternalWorkerJobFailureBuilder	errorMessage(String errorMessage) The error message for the failing job.
void	fail() Perform the logic for failing a job.
ExternalWorkerJobFailureBuilder	retries(int retries) The number of new retries that should be set for the job.
ExternalWorkerJobFailureBuilder	retryTimeout(Duration retryTimeout) The amount of time to wait before making the job available for a retry.

Methods inherited from class java.lang.Object

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

Field Detail

externalJobId

protected final String externalJobId

workerId

protected final String workerId

commandExecutor

protected final CommandExecutor commandExecutor

jobServiceConfiguration

protected final JobServiceConfiguration jobServiceConfiguration

errorMessage

protected String errorMessage

errorDetails

protected String errorDetails

retries

protected int retries

retryTimeout

protected Duration retryTimeout

Constructor Detail

ExternalWorkerJobFailureBuilderImpl

public ExternalWorkerJobFailureBuilderImpl(String externalJobId,
                                           String workerId,
                                           CommandExecutor commandExecutor,
                                           JobServiceConfiguration jobServiceConfiguration)

Method Detail

errorMessage

public ExternalWorkerJobFailureBuilder errorMessage(String errorMessage)

Description copied from interface: ExternalWorkerJobFailureBuilder

The error message for the failing job.

Specified by:

errorMessage in interface ExternalWorkerJobFailureBuilder

errorDetails

public ExternalWorkerJobFailureBuilder errorDetails(String errorDetails)

Description copied from interface: ExternalWorkerJobFailureBuilder

The longer error details for the failing job.

Specified by:

errorDetails in interface ExternalWorkerJobFailureBuilder

retries

public ExternalWorkerJobFailureBuilder retries(int retries)

Description copied from interface: ExternalWorkerJobFailureBuilder

The number of new retries that should be set for the job. If not set then the retries count would be decreased by 1. If the current retries is already 1, the job will be moved to the deadletter job table.

Specified by:

retries in interface ExternalWorkerJobFailureBuilder

retryTimeout

public ExternalWorkerJobFailureBuilder retryTimeout(Duration retryTimeout)

Description copied from interface: ExternalWorkerJobFailureBuilder

The amount of time to wait before making the job available for a retry. If nothing set then the job would immediately be available for a retry.

Specified by:

retryTimeout in interface ExternalWorkerJobFailureBuilder

fail

public void fail()

Description copied from interface: ExternalWorkerJobFailureBuilder

Perform the logic for failing a job.

Specified by:

fail in interface ExternalWorkerJobFailureBuilder