org.camunda.bpm.engine.impl.interceptor

Class JtaRetryInterceptor

java.lang.Object

org.camunda.bpm.engine.impl.interceptor.CommandInterceptor

org.camunda.bpm.engine.impl.interceptor.RetryInterceptor

org.camunda.bpm.engine.impl.interceptor.JtaRetryInterceptor

All Implemented Interfaces:

CommandExecutor

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 OptimisticLockingException.

Author:

Daniel Meyer

Field Summary

Fields

Modifier and Type	Field and Description
protected TransactionManager	transactionManager

Fields inherited from class org.camunda.bpm.engine.impl.interceptor.RetryInterceptor

numOfRetries, waitIncreaseFactor, waitTimeInMs

Fields inherited from class org.camunda.bpm.engine.impl.interceptor.CommandInterceptor

next

Constructor Summary

Constructors

Constructor and Description
JtaRetryInterceptor(TransactionManager transactionManager)

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	calledInsideTransaction()
<T> T	execute(Command<T> command)

Methods inherited from class org.camunda.bpm.engine.impl.interceptor.RetryInterceptor

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

Methods inherited from class org.camunda.bpm.engine.impl.interceptor.CommandInterceptor

getNext, setNext

Methods inherited from class java.lang.Object

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

Field Detail

transactionManager

protected final TransactionManager transactionManager

Constructor Detail

JtaRetryInterceptor

public JtaRetryInterceptor(TransactionManager transactionManager)

Method Detail

execute

public <T> T execute(Command<T> command)

Specified by:

execute in interface CommandExecutor

Overrides:

execute in class RetryInterceptor

calledInsideTransaction

protected boolean calledInsideTransaction()