org.openspaces.core.gateway

Class GatewaySinkDistributedTransactionProcessingConfigurationFactoryBean

java.lang.Object

org.openspaces.core.transaction.DistributedTransactionProcessingConfigurationFactoryBean

org.openspaces.core.gateway.GatewaySinkDistributedTransactionProcessingConfigurationFactoryBean

public class GatewaySinkDistributedTransactionProcessingConfigurationFactoryBean
extends DistributedTransactionProcessingConfigurationFactoryBean

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

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

Since:

9.0.1

Author:

eitany

Constructor Summary

Constructors

Constructor and Description
GatewaySinkDistributedTransactionProcessingConfigurationFactoryBean()

Method Summary

Modifier and Type	Method and Description
void	copyParameters(com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile.DistributedTransactionProcessingConfiguration transactionProcessingConfiguration)
String	getDistributedTransactionConsolidationFailureAction()
void	setDistributedTransactionConsolidationFailureAction(String distributedTransactionConsolidationFailureAction)

Methods inherited from class org.openspaces.core.transaction.DistributedTransactionProcessingConfigurationFactoryBean

getDistributedTransactionWaitForOperations, getDistributedTransactionWaitTimeout, isMonitorPendingOperationsMemory, setDistributedTransactionWaitForOperations, setDistributedTransactionWaitTimeout, setMonitorPendingOperationsMemory

Methods inherited from class java.lang.Object

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

Constructor Detail

GatewaySinkDistributedTransactionProcessingConfigurationFactoryBean

public GatewaySinkDistributedTransactionProcessingConfigurationFactoryBean()

Method Detail

setDistributedTransactionConsolidationFailureAction

public void setDistributedTransactionConsolidationFailureAction(String distributedTransactionConsolidationFailureAction)

Parameters:

distributedTransactionConsolidationFailureAction - the distributedTransactionConsolidationFailedAction to set

getDistributedTransactionConsolidationFailureAction

public String getDistributedTransactionConsolidationFailureAction()

Returns:

the distributedTransactionConsolidationFailedAction

copyParameters

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