Modifier and Type | Class and Description |
---|---|
protected class |
FailedJobListener.FailedJobListenerCmd |
Modifier and Type | Field and Description |
---|---|
protected CommandExecutor |
commandExecutor |
protected int |
countRetries |
protected JobFailureCollector |
jobFailureCollector |
protected int |
totalRetries |
Constructor and Description |
---|
FailedJobListener(CommandExecutor commandExecutor,
JobFailureCollector jobFailureCollector) |
Modifier and Type | Method and Description |
---|---|
Void |
execute(CommandContext commandContext) |
protected void |
fireHistoricJobFailedEvt(JobEntity job) |
int |
getRetriesLeft() |
void |
incrementCountRetries() |
protected void |
logJobFailure(CommandContext commandContext) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isRetryable
protected CommandExecutor commandExecutor
protected JobFailureCollector jobFailureCollector
protected int countRetries
protected int totalRetries
public FailedJobListener(CommandExecutor commandExecutor, JobFailureCollector jobFailureCollector)
public Void execute(CommandContext commandContext)
protected void fireHistoricJobFailedEvt(JobEntity job)
protected void logJobFailure(CommandContext commandContext)
public void incrementCountRetries()
public int getRetriesLeft()
Copyright © 2022. All rights reserved.