org.openspaces.core.transaction
Class DistributedTransactionProcessingConfigurationFactoryBean

java.lang.Object
  org.openspaces.core.transaction.DistributedTransactionProcessingConfigurationFactoryBean

public class DistributedTransactionProcessingConfigurationFactoryBean
extends Object

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

• #setDistributedTransactionWaitTimeout(Float) - determines the wait timeout for all distributed transaction participants data before committing only the data that arrived.
• #setDistributedTransactionWaitForOperations(Integer) - 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

DistributedTransactionProcessingConfigurationFactoryBean()

Method Summary

void	copyParameters(com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile.DistributedTransactionProcessingConfiguration transactionProcessingConfiguration)
Long	getDistributedTransactionWaitForOperations()
Long	getDistributedTransactionWaitTimeout()
void	setDistributedTransactionWaitForOperations(Long distributedTransactionWaitForOperations)
void	setDistributedTransactionWaitTimeout(Long distributedTransactionWaitTimeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedTransactionProcessingConfigurationFactoryBean

public DistributedTransactionProcessingConfigurationFactoryBean()

Method Detail

getDistributedTransactionWaitTimeout

public Long getDistributedTransactionWaitTimeout()

setDistributedTransactionWaitTimeout

public void setDistributedTransactionWaitTimeout(Long distributedTransactionWaitTimeout)

getDistributedTransactionWaitForOperations

public Long getDistributedTransactionWaitForOperations()

setDistributedTransactionWaitForOperations

public void setDistributedTransactionWaitForOperations(Long distributedTransactionWaitForOperations)

copyParameters

public void copyParameters(com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile.DistributedTransactionProcessingConfiguration transactionProcessingConfiguration)