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

Class ReplicationParticipantsMediator

java.lang.Object

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

All Implemented Interfaces:

IReplicationParticipantsMediator

public class ReplicationParticipantsMediator
extends Object
implements IReplicationParticipantsMediator

Since:

8.0.4

Author:

idan

Constructor Summary

Constructors

Constructor	Description
ReplicationParticipantsMediator()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

ReplicationParticipantsMediator

public ReplicationParticipantsMediator()

Method Details

getAllParticipantsData

public IReplicationPacketData<?>[] getAllParticipantsData(MultiSourceProcessLogPacket packet)

Description copied from interface: IReplicationParticipantsMediator

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

Specified by:

getAllParticipantsData in interface IReplicationParticipantsMediator

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

public boolean isConsumed(Object contextId)

Specified by:

isConsumed in interface IReplicationParticipantsMediator

Returns:

true if the provided contextId associated operation has been consumed.

setConsumed

public void setConsumed(IReplicationParticipantsMetadata participantsMetadata)

Description copied from interface: IReplicationParticipantsMediator

Sets the provided contextId as consumed.

Specified by:

setConsumed in interface IReplicationParticipantsMediator

remove

public void remove(IReplicationParticipantsMetadata participantsMetadata)

Description copied from interface: IReplicationParticipantsMediator

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

Specified by:

remove in interface IReplicationParticipantsMediator

abortConsolidation

public boolean abortConsolidation(IReplicationParticipantsMetadata participantsMetadata)

Description copied from interface: IReplicationParticipantsMediator

Attempts to abort consolidation for the provided meta data.

Specified by:

abortConsolidation in interface IReplicationParticipantsMediator

Returns:

true if successfully aborted, otherwise false.