GatewaySinkDistributedTransactionProcessingConfigurationFactoryBean (GigaSpaces XAP 9.7.2 API)

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

GigaSpaces XAP 9.7.2 API

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.openspaces.core.gateway
Class GatewaySinkDistributedTransactionProcessingConfigurationFactoryBean

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

public class GatewaySinkDistributedTransactionProcessingConfigurationFactoryBean
extends DistributedTransactionProcessingConfigurationFactoryBean
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
`GatewaySinkDistributedTransactionProcessingConfigurationFactoryBean()`

Method Summary
`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)