GigaSpaces XAP 9.7.2 API

org.openspaces.persistency.patterns
Class SpaceSynchronizationEndpointSplitter

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

public class SpaceSynchronizationEndpointSplitter
extends SpaceSynchronizationEndpoint

A SpaceSynchronizationEndpoint that implements the synchronization methods. Reshuffles the given synchronization operations by grouping them based on the types and then calls the corresponding synchronization method for each type respective synchronization endpoint.

Since:
9.5
Author:
eitany

Constructor Summary
SpaceSynchronizationEndpointSplitter(ManagedEntriesSpaceSynchronizationEndpoint[] dataSources)
           
 
Method Summary
 void afterOperationsBatchSynchronization(OperationsBatchData batchData)
          split the batch into multiple batches according to their entry type and delegate it to the corresponding synchronization endpoint interceptor SpaceSynchronizationEndpoint.afterOperationsBatchSynchronization(OperationsBatchData)
 void afterTransactionSynchronization(TransactionData transactionData)
          split the transaction data into multiple transaction data according to their entry type and delegate it to the corresponding synchronization endpoint interceptor SpaceSynchronizationEndpoint.afterTransactionSynchronization(TransactionData).
protected  SpaceSynchronizationEndpoint getEndpoint(String entry)
           
 void onAddIndex(AddIndexData addIndexData)
          delegate the add index event to the corresponding interceptor
 void onIntroduceType(IntroduceTypeData introduceTypeData)
          delegate the introduce type event to the corresponding interceptor
 void onOperationsBatchSynchronization(OperationsBatchData batchData)
          split the batch into multiple batches according to their entry type and delegate it to the corresponding synchronization endpoint interceptor SpaceSynchronizationEndpoint.onOperationsBatchSynchronization(OperationsBatchData)
 void onTransactionSynchronization(TransactionData transactionData)
          split the transaction data into multiple transaction data according to their entry type and delegate it to the corresponding synchronization endpoint interceptor SpaceSynchronizationEndpoint.onTransactionSynchronization(TransactionData).
 
Methods inherited from class com.gigaspaces.sync.SpaceSynchronizationEndpoint
onTransactionConsolidationFailure
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SpaceSynchronizationEndpointSplitter

public SpaceSynchronizationEndpointSplitter(ManagedEntriesSpaceSynchronizationEndpoint[] dataSources)
Method Detail

getEndpoint

protected SpaceSynchronizationEndpoint getEndpoint(String entry)

onOperationsBatchSynchronization

public void onOperationsBatchSynchronization(OperationsBatchData batchData)
split the batch into multiple batches according to their entry type and delegate it to the corresponding synchronization endpoint interceptor SpaceSynchronizationEndpoint.onOperationsBatchSynchronization(OperationsBatchData)

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

afterOperationsBatchSynchronization

public void afterOperationsBatchSynchronization(OperationsBatchData batchData)
split the batch into multiple batches according to their entry type and delegate it to the corresponding synchronization endpoint interceptor SpaceSynchronizationEndpoint.afterOperationsBatchSynchronization(OperationsBatchData)

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

onTransactionSynchronization

public void onTransactionSynchronization(TransactionData transactionData)
split the transaction data into multiple transaction data according to their entry type and delegate it to the corresponding synchronization endpoint interceptor SpaceSynchronizationEndpoint.onTransactionSynchronization(TransactionData). This may break transaction atomicity if one of the delegated synchronization endpoint interceptor throws an exception while other did not.

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

afterTransactionSynchronization

public void afterTransactionSynchronization(TransactionData transactionData)
split the transaction data into multiple transaction data according to their entry type and delegate it to the corresponding synchronization endpoint interceptor SpaceSynchronizationEndpoint.afterTransactionSynchronization(TransactionData).

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

onAddIndex

public void onAddIndex(AddIndexData addIndexData)
delegate the add index event to the corresponding interceptor

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

onIntroduceType

public void onIntroduceType(IntroduceTypeData introduceTypeData)
delegate the introduce type event to the corresponding interceptor

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

GigaSpaces XAP 9.7.2 API

Copyright © GigaSpaces.