Class FailedJobListener
- java.lang.Object
-
- org.camunda.bpm.engine.impl.jobexecutor.FailedJobListener
-
-
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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.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 Detail
-
commandExecutor
protected CommandExecutor commandExecutor
-
jobFailureCollector
protected JobFailureCollector jobFailureCollector
-
countRetries
protected int countRetries
-
totalRetries
protected int totalRetries
-
-
Constructor Detail
-
FailedJobListener
public FailedJobListener(CommandExecutor commandExecutor, JobFailureCollector jobFailureCollector)
-
-
Method Detail
-
execute
public java.lang.Void execute(CommandContext commandContext)
-
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()
-
-