Package org.camunda.bpm.engine.impl.jobexecutor

Class FailedJobListener

java.lang.Object

org.camunda.bpm.engine.impl.jobexecutor.FailedJobListener

All Implemented Interfaces:

Command<Void>

public class FailedJobListener
extends Object
implements Command<Void>

Author:

Frederik Heremans, Bernd Ruecker

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	FailedJobListener.FailedJobListenerCmd

Field Summary

Fields

Modifier and Type	Field	Description
protected CommandExecutor	commandExecutor
protected int	countRetries
protected JobFailureCollector	jobFailureCollector
protected int	totalRetries

Constructor Summary

Constructors

Constructor	Description
FailedJobListener(CommandExecutor commandExecutor, JobFailureCollector jobFailureCollector)

Method Summary

Modifier and Type	Method	Description
Void	execute(CommandContext commandContext)
protected void	fireHistoricJobFailedEvt(JobEntity job)
int	getRetriesLeft()
void	incrementCountRetries()
protected boolean	isJobReacquired(CommandContext commandContext)
protected void	logJobFailure(CommandContext commandContext)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.camunda.bpm.engine.impl.interceptor.Command

isRetryable

Field Details

commandExecutor

protected CommandExecutor commandExecutor

jobFailureCollector

protected JobFailureCollector jobFailureCollector

countRetries

protected int countRetries

totalRetries

protected int totalRetries

Constructor Details

FailedJobListener

public FailedJobListener(CommandExecutor commandExecutor,
 JobFailureCollector jobFailureCollector)

Method Details

execute

public Void execute(CommandContext commandContext)

Specified by:

execute in interface Command<Void>

isJobReacquired

protected boolean isJobReacquired(CommandContext commandContext)

fireHistoricJobFailedEvt

protected void fireHistoricJobFailedEvt(JobEntity job)

logJobFailure

protected void logJobFailure(CommandContext commandContext)

incrementCountRetries

public void incrementCountRetries()

getRetriesLeft

public int getRetriesLeft()