Package 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 Details

    • SynchronizationEndpointInterceptor

      public SynchronizationEndpointInterceptor()

  • Method Details

    • 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