com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile

Interface IReplicationParticipantsMediator

All Known Implementing Classes:

ReplicationParticipantsMediator

public interface IReplicationParticipantsMediator

Responsible for synchronizing replication process logs multiple participants operations in a reliable async target.

Since:

8.0.4

Author:

idan

Method Summary

Modifier and Type	Method and Description
boolean	abortConsolidation(IReplicationParticipantsMetadata participantsMetadata) Attempts to abort consolidation for the provided meta data.
IReplicationPacketData<?>[]	getAllParticipantsData(MultiSourceProcessLogPacket packet) Gets all data for a multiple participants replication operation.
boolean	isConsumed(Object contextId)
void	remove(IReplicationParticipantsMetadata participantsMetadata) Removes multiple participant context from mediator according to the provided meta data.
void	setConsumed(IReplicationParticipantsMetadata participantsMetadata) Sets the provided contextId as consumed.

Method Detail

getAllParticipantsData

IReplicationPacketData<?>[] getAllParticipantsData(MultiSourceProcessLogPacket packet)

Gets all data for a multiple participants replication operation. If not all data arrived the return value is null.

Parameters:

packet - The packet to be added to the context in case not all packets arrived.

Returns:

All data if all data arrived, otherwise null.

isConsumed

boolean isConsumed(Object contextId)

Returns:

true if the provided contextId associated operation has been consumed.

setConsumed

void setConsumed(IReplicationParticipantsMetadata participantsMetadata)

Sets the provided contextId as consumed.

remove

void remove(IReplicationParticipantsMetadata participantsMetadata)

Removes multiple participant context from mediator according to the provided meta data.

abortConsolidation

boolean abortConsolidation(IReplicationParticipantsMetadata participantsMetadata)

Attempts to abort consolidation for the provided meta data.

Returns:

true if aborted successfully, false if already consolidated.