Package org.openspaces.persistency.kafka

Class KafkaSpaceSynchronizationEndpoint

java.lang.Object

com.gigaspaces.sync.SpaceSynchronizationEndpoint

org.openspaces.persistency.kafka.KafkaSpaceSynchronizationEndpoint

public class KafkaSpaceSynchronizationEndpoint
extends SpaceSynchronizationEndpoint

Field Summary

Fields

Modifier and Type	Field	Description
static final long	KAFKA_TIMEOUT

Constructor Summary

Constructors

Constructor	Description
KafkaSpaceSynchronizationEndpoint(SpaceSynchronizationEndpoint primaryEndpoint, Map<String,SpaceSynchronizationEndpoint> secondaryEndpoints, Properties kafkaProps, String topic)

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	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 com.gigaspaces.sync.SpaceSynchronizationEndpoint

afterOperationsBatchSynchronization, afterTransactionSynchronization

Methods inherited from class java.lang.Object

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

Field Details

KAFKA_TIMEOUT

public static final long KAFKA_TIMEOUT

See Also:

• Constant Field Values

Constructor Details

KafkaSpaceSynchronizationEndpoint

public KafkaSpaceSynchronizationEndpoint(SpaceSynchronizationEndpoint primaryEndpoint,
 Map<String,SpaceSynchronizationEndpoint> secondaryEndpoints,
 Properties kafkaProps,
 String topic)

Method Details

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

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

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

close

public void close()