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

Class JtaRetryInterceptor

java.lang.Object

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

org.flowable.common.engine.impl.interceptor.RetryInterceptor

org.flowable.common.engine.impl.interceptor.JtaRetryInterceptor

All Implemented Interfaces:

CommandInterceptor

public class JtaRetryInterceptor
extends RetryInterceptor

We cannot perform a retry if we are called in an existing transaction. In that case, the transaction will be marked "rollback-only" after the first FlowableOptimisticLockingException.

Author:

Daniel Meyer

Field Summary

Fields

Modifier and Type	Field	Description
protected final jakarta.transaction.TransactionManager	transactionManager

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

numOfRetries, waitIncreaseFactor, waitTimeInMs

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

next

Constructor Summary

Constructors

Constructor	Description
JtaRetryInterceptor(jakarta.transaction.TransactionManager transactionManager)

Method Summary

Modifier and Type	Method	Description
protected boolean	calledInsideTransaction()
<T> T	execute(CommandConfig config, Command<T> command, CommandExecutor commandExecutor)

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

getNumOfRetries, getWaitIncreaseFactor, getWaitTimeInMs, setNumOfRetries, setWaitIncreaseFactor, setWaitTimeInMs, waitBeforeRetry

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

transactionManager

protected final jakarta.transaction.TransactionManager transactionManager

Constructor Details

JtaRetryInterceptor

public JtaRetryInterceptor(jakarta.transaction.TransactionManager transactionManager)

Method Details

execute

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

Specified by:

execute in interface CommandInterceptor

Overrides:

execute in class RetryInterceptor

calledInsideTransaction

protected boolean calledInsideTransaction()