GigaSpaces XAP 9.7.2 API

org.openspaces.persistency.patterns
Class SpaceSynchronizationEndpointExceptionHandler

java.lang.Object
  extended by com.gigaspaces.sync.SpaceSynchronizationEndpoint
      extended by org.openspaces.persistency.patterns.SpaceSynchronizationEndpointExceptionHandler

public class SpaceSynchronizationEndpointExceptionHandler
extends SpaceSynchronizationEndpoint

An exception handler that delegates SpaceSynchronizationEndpoint execution and calls the provided PersistencyExceptionHandler in case of exceptions on synchronization methods.

Since:
9.5
Author:
eitany

Constructor Summary
SpaceSynchronizationEndpointExceptionHandler(SpaceSynchronizationEndpoint interceptor, PersistencyExceptionHandler exceptionHandler)
           
 
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

SpaceSynchronizationEndpointExceptionHandler

public SpaceSynchronizationEndpointExceptionHandler(SpaceSynchronizationEndpoint interceptor,
                                                    PersistencyExceptionHandler exceptionHandler)
Method Detail

onTransactionConsolidationFailure

public void onTransactionConsolidationFailure(ConsolidationParticipantData participantData)
Description copied from class: SpaceSynchronizationEndpoint
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.

Overrides:
onTransactionConsolidationFailure in class SpaceSynchronizationEndpoint
Parameters:
participantData - the transaction participant data for which the consolidation failed

onTransactionSynchronization

public void onTransactionSynchronization(TransactionData transactionData)
Description copied from class: SpaceSynchronizationEndpoint
Triggered on synchronization of a transaction.

Overrides:
onTransactionSynchronization in class SpaceSynchronizationEndpoint
Parameters:
transactionData - the transaction data

afterTransactionSynchronization

public void afterTransactionSynchronization(TransactionData transactionData)
Description copied from class: SpaceSynchronizationEndpoint
Triggered after synchronization of a transaction was completed successfully.

Overrides:
afterTransactionSynchronization in class SpaceSynchronizationEndpoint
Parameters:
transactionData - the transaction data

onOperationsBatchSynchronization

public void onOperationsBatchSynchronization(OperationsBatchData batchData)
Description copied from class: SpaceSynchronizationEndpoint
Triggered on synchronization batch of operations.

Overrides:
onOperationsBatchSynchronization in class SpaceSynchronizationEndpoint
Parameters:
batchData - the batched operations data

afterOperationsBatchSynchronization

public void afterOperationsBatchSynchronization(OperationsBatchData batchData)
Description copied from class: SpaceSynchronizationEndpoint
Triggered after synchronization batch of operations was completed successfully.

Overrides:
afterOperationsBatchSynchronization in class SpaceSynchronizationEndpoint
Parameters:
batchData - the batched operations data

onAddIndex

public void onAddIndex(AddIndexData addIndexData)
Description copied from class: SpaceSynchronizationEndpoint
Triggered on add index synchronization.

Overrides:
onAddIndex in class SpaceSynchronizationEndpoint
Parameters:
addIndexData - The added index data

onIntroduceType

public void onIntroduceType(IntroduceTypeData introduceTypeData)
Description copied from class: SpaceSynchronizationEndpoint
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.

Overrides:
onIntroduceType in class SpaceSynchronizationEndpoint
Parameters:
introduceTypeData - The introduced type data

GigaSpaces XAP 9.7.2 API

Copyright © GigaSpaces.