Package com.gigaspaces.persistency

Class MongoSpaceSynchronizationEndpoint

java.lang.Object

com.gigaspaces.sync.SpaceSynchronizationEndpoint

com.gigaspaces.persistency.MongoSpaceSynchronizationEndpoint

public class MongoSpaceSynchronizationEndpoint
extends SpaceSynchronizationEndpoint

A MongoDB implementation of SpaceSynchronizationEndpoint

Author:

Shadi Massalha

Constructor Summary

Constructors

Constructor	Description
MongoSpaceSynchronizationEndpoint(MongoClientConnector client)

Method Summary

Modifier and Type	Method	Description
void	close()
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	onTransactionSynchronization(TransactionData transactionData)	Triggered on synchronization of a transaction.

Methods inherited from class com.gigaspaces.sync.SpaceSynchronizationEndpoint

afterOperationsBatchSynchronization, afterTransactionSynchronization, onTransactionConsolidationFailure

Methods inherited from class java.lang.Object

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

Constructor Details

MongoSpaceSynchronizationEndpoint

public MongoSpaceSynchronizationEndpoint(MongoClientConnector client)

Method Details

close

public void close()
           throws IOException

Throws:

IOException

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

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

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

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