Package com.gigaspaces.sync

Class SpaceSynchronizationEndpoint

java.lang.Object
com.gigaspaces.sync.SpaceSynchronizationEndpoint
Direct Known Subclasses:
CassandraSpaceSynchronizationEndpoint, EDSAdapterSynchronizationEndpoint, GigaSpaceSynchronizationEndpoint, KafkaSpaceSynchronizationEndpoint, ManagedEntriesSpaceSynchronizationEndpoint, MongoSpaceSynchronizationEndpoint, SpaceSynchronizationEndpointExceptionHandler, SpaceSynchronizationEndpointSplitter
public class SpaceSynchronizationEndpoint extends Object
A space synchronization endpoint used to intercept incoming replication events which were originated from a space and do custom behavior when this events occur.
Since:
9.1.1
Author:
eitany

  • Constructor Details

    • SpaceSynchronizationEndpoint

      public SpaceSynchronizationEndpoint()

  • 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

    • onTransactionSynchronization

      public void onTransactionSynchronization(TransactionData transactionData)
      Triggered on synchronization of a transaction.
      Parameters:
      transactionData - the transaction data

    • afterTransactionSynchronization

      public void afterTransactionSynchronization(TransactionData transactionData)
      Triggered after synchronization of a transaction was completed successfully.
      Parameters:
      transactionData - the transaction data

    • onOperationsBatchSynchronization

      public void onOperationsBatchSynchronization(OperationsBatchData batchData)
      Triggered on synchronization batch of operations.
      Parameters:
      batchData - the batched operations data

    • afterOperationsBatchSynchronization

      public void afterOperationsBatchSynchronization(OperationsBatchData batchData)
      Triggered after synchronization batch of operations was completed successfully.
      Parameters:
      batchData - the batched operations data

    • onAddIndex

      public void onAddIndex(AddIndexData addIndexData)
      Triggered on add index synchronization.
      Parameters:
      addIndexData - The added index data

    • onIntroduceType

      public void onIntroduceType(IntroduceTypeData introduceTypeData)
      Triggered on type data introduction. This method may be invoked more than once for the same type during the life time of this endpoint and it is up to the implementor to handle this scenario gracefully.
      Parameters:
      introduceTypeData - The introduced type data