com.gigaspaces.sync

Class SynchronizationEndpointInterceptor

java.lang.Object

com.gigaspaces.sync.SynchronizationEndpointInterceptor

Direct Known Subclasses:

AbortOnConsolidationFailureInterceptor, CommitOnConsolidationFailureInterceptor

public abstract class SynchronizationEndpointInterceptor
extends Object

A synchronization endpoint interceptor used to intercept incoming replication events and do custom behavior when this events occur.

Since:

9.0.1

Author:

eitany

Constructor Summary

Constructors

Constructor and Description
SynchronizationEndpointInterceptor()

Method Summary

Modifier and Type	Method and Description
void	afterOperationsBatchSynchronization(OperationsBatchData batchData) Triggered after synchronization batch of operations was completed successfully.
void	afterTransactionSynchronization(TransactionData transactionData) Triggered after synchronization of a transaction was completed successfully.
void	onTransactionConsolidationFailure(ConsolidationParticipantData participantData) Triggered when a consolidation for a specific distributed transaction participant is failed due to timeout or too much backlog accumulation while waiting for other participant parts.

Methods inherited from class java.lang.Object

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

Constructor Detail

SynchronizationEndpointInterceptor

public SynchronizationEndpointInterceptor()

Method Detail

onTransactionConsolidationFailure

public void onTransactionConsolidationFailure(ConsolidationParticipantData participantData)

Triggered when a consolidation for a specific distributed transaction participant is failed due to timeout or too much backlog accumulation while waiting for other participant parts.

Parameters:

participantData - the transaction participant data for which the consolidation failed

afterTransactionSynchronization

public void afterTransactionSynchronization(TransactionData transactionData)

Triggered after synchronization of a transaction was completed successfully.

Parameters:

transactionData - the transaction data

afterOperationsBatchSynchronization

public void afterOperationsBatchSynchronization(OperationsBatchData batchData)

Triggered after synchronization batch of operations was completed successfully.

Parameters:

batchData - the batched operations data