Package org.openspaces.core.transaction

Class DistributedTransactionProcessingConfigurationFactoryBean

java.lang.Object

org.openspaces.core.transaction.DistributedTransactionProcessingConfigurationFactoryBean

Direct Known Subclasses:

GatewaySinkDistributedTransactionProcessingConfigurationFactoryBean

public class DistributedTransactionProcessingConfigurationFactoryBean
extends Object

A bean for configuring distributed transaction processing at Mirror component. Its possible to configure two parameters:

• setDistributedTransactionWaitTimeout(Long) - determines the wait timeout for all distributed transaction participants data before committing only the data that arrived.
• setDistributedTransactionWaitForOperations(Long) - determines the number of operations to wait for before committing a distributed transaction when data from all participants haven't arrived.

Since:

8.0.4

Author:

idan

Constructor Summary

Constructors

Constructor	Description
DistributedTransactionProcessingConfigurationFactoryBean()

Method Summary

Modifier and Type	Method	Description
Long	getDistributedTransactionWaitForOperations()
Long	getDistributedTransactionWaitTimeout()
Boolean	isMonitorPendingOperationsMemory()
void	setDistributedTransactionWaitForOperations(Long distributedTransactionWaitForOperations)
void	setDistributedTransactionWaitTimeout(Long distributedTransactionWaitTimeout)
void	setMonitorPendingOperationsMemory(Boolean monitorPendingOperationsMemory)

Methods inherited from class java.lang.Object

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

Constructor Details

DistributedTransactionProcessingConfigurationFactoryBean

public DistributedTransactionProcessingConfigurationFactoryBean()

Method Details

getDistributedTransactionWaitTimeout

public Long getDistributedTransactionWaitTimeout()

setDistributedTransactionWaitTimeout

public void setDistributedTransactionWaitTimeout(Long distributedTransactionWaitTimeout)

getDistributedTransactionWaitForOperations

public Long getDistributedTransactionWaitForOperations()

setDistributedTransactionWaitForOperations

public void setDistributedTransactionWaitForOperations(Long distributedTransactionWaitForOperations)

isMonitorPendingOperationsMemory

public Boolean isMonitorPendingOperationsMemory()

setMonitorPendingOperationsMemory

public void setMonitorPendingOperationsMemory(Boolean monitorPendingOperationsMemory)