com.gigaspaces.sync
Class SpaceSynchronizationEndpoint

java.lang.Object
  com.gigaspaces.sync.SpaceSynchronizationEndpoint

Direct Known Subclasses:

CassandraSpaceSynchronizationEndpoint

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 Summary

SpaceSynchronizationEndpoint()

Method Summary

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	onAddIndex(AddIndexData addIndexData) Triggered on add index synchronization.
void	onIntroduceType(IntroduceTypeData introduceTypeData) Triggered on type data introduction.
void	onOperationsBatchSynchronization(OperationsBatchData batchData) Triggered on synchronization batch of operations.
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.
void	onTransactionSynchronization(TransactionData transactionData) Triggered on synchronization of a transaction.

Methods inherited from class java.lang.Object

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

Constructor Detail

SpaceSynchronizationEndpoint

public SpaceSynchronizationEndpoint()

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

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.

Parameters:

introduceTypeData - The introduced type data