Package org.flowable.common.engine.impl.interceptor

Class CrDbRetryInterceptor

java.lang.Object

org.flowable.common.engine.impl.interceptor.AbstractCommandInterceptor

org.flowable.common.engine.impl.interceptor.CrDbRetryInterceptor

All Implemented Interfaces:

CommandInterceptor

public class CrDbRetryInterceptor
extends AbstractCommandInterceptor

Inspired by RetryInterceptor, but adapted for CRDB. This probably won't work in environments such as Spring if the transaction is externally managed

Author:

Joram Barrez

Field Summary

Fields

Modifier and Type	Field	Description
protected int	nrRetries
protected int	waitTime
protected int	waitTimeIncrease

Fields inherited from class org.flowable.common.engine.impl.interceptor.AbstractCommandInterceptor

next

Constructor Summary

Constructors

Constructor	Description
CrDbRetryInterceptor()

Method Summary

Modifier and Type	Method	Description
<T> T	execute(CommandConfig config, Command<T> command, CommandExecutor commandExecutor)
protected boolean	isTransactionRetryException(Throwable exception)
protected void	waitBeforeRetry(long waitTime)

Methods inherited from class org.flowable.common.engine.impl.interceptor.AbstractCommandInterceptor

getNext, setNext

Methods inherited from class java.lang.Object

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

Field Details

nrRetries

protected int nrRetries

waitTime

protected int waitTime

waitTimeIncrease

protected int waitTimeIncrease

Constructor Details

CrDbRetryInterceptor

public CrDbRetryInterceptor()

Method Details

execute

public <T> T execute(CommandConfig config,
 Command<T> command,
 CommandExecutor commandExecutor)

waitBeforeRetry

protected void waitBeforeRetry(long waitTime)

isTransactionRetryException

protected boolean isTransactionRetryException(Throwable exception)