Package org.openspaces.persistency.patterns

Class SpaceSynchronizationEndpointSplitter

java.lang.Object

com.gigaspaces.sync.SpaceSynchronizationEndpoint

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

Constructors

Constructor	Description
SpaceSynchronizationEndpointSplitter(ManagedEntriesSpaceSynchronizationEndpoint[] dataSources)

Method Summary

Modifier and Type	Method	Description
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 Details

SpaceSynchronizationEndpointSplitter

public SpaceSynchronizationEndpointSplitter(ManagedEntriesSpaceSynchronizationEndpoint[] dataSources)

Method Details

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