com.gigaspaces.internal.cluster.node.impl.packets.data

Class ReplicationPacketDataConsumer

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.packets.data.ReplicationPacketDataConsumer

All Implemented Interfaces:

IReplicationPacketDataBatchConsumer<IExecutableReplicationPacketData<?>>, IReplicationPacketDataConsumer<IExecutableReplicationPacketData<?>>

Direct Known Subclasses:

BlobstoreReplicationPacketDataConsumer

public class ReplicationPacketDataConsumer
extends Object
implements IReplicationPacketDataBatchConsumer<IExecutableReplicationPacketData<?>>

Constructor Summary

Constructors

Constructor and Description
ReplicationPacketDataConsumer(SpaceTypeManager typeManager, IDataConsumeFixFacade fixFacade, ReplicationPacketDataMediator packetDataMediator)

Method Summary

Modifier and Type	Method and Description
IExecutableReplicationPacketData<?>	applyFix(IReplicationInContext context, IExecutableReplicationPacketData<?> data, IDataConsumeFix fix) Apply a fix to a data, the fix is generated due to a failed consumption of IReplicationPacketData
IDataConsumeResult	consume(IReplicationInContext context, IExecutableReplicationPacketData<?> data, IReplicationInFacade replicationInFacade, IReplicationInFilterCallback inFilterCallback) Consumes a IReplicationPacketData and delegate the operation is represents to the corresponding method at the given IReplicationInFacade
IDataConsumeResult	consumePendingPackets(IReplicationInBatchContext context, IReplicationInFacade replicationInFacade) Consume packets which are pending in the provided batch context.
IReplicationParticipantsMetadata	extractParticipantsMetadata(IReplicationPacketData<?> data) Extracts participants meta data for the provided replication packet data
SpaceTypeManager	getTypeManager()
IReplicationPacketData<?>	merge(IReplicationPacketData<?>[] allParticipantsData, IReplicationParticipantsMetadata participantsMetadata) Merges data of multiple participants operations to a single operation data which will eventually be executed as one.
Iterable<IReplicationFilterEntry>	toFilterEntries(IReplicationInContext context, IReplicationPacketData<?> data) Transform generated data to filter entry in order to be passed to a filter

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationPacketDataConsumer

public ReplicationPacketDataConsumer(SpaceTypeManager typeManager,
                                     IDataConsumeFixFacade fixFacade,
                                     ReplicationPacketDataMediator packetDataMediator)

Method Detail

consume

public IDataConsumeResult consume(IReplicationInContext context,
                                  IExecutableReplicationPacketData<?> data,
                                  IReplicationInFacade replicationInFacade,
                                  IReplicationInFilterCallback inFilterCallback)

Description copied from interface: IReplicationPacketDataConsumer

Consumes a IReplicationPacketData and delegate the operation is represents to the corresponding method at the given IReplicationInFacade

Specified by:

consume in interface IReplicationPacketDataConsumer<IExecutableReplicationPacketData<?>>

data - operation to consume and translate to an operation

replicationInFacade - facade to delegate the data as incoming replication

Returns:

consumption result that indicates success consumption or error

applyFix

public IExecutableReplicationPacketData<?> applyFix(IReplicationInContext context,
                                                    IExecutableReplicationPacketData<?> data,
                                                    IDataConsumeFix fix)
                                             throws Exception

Description copied from interface: IReplicationPacketDataConsumer

Apply a fix to a data, the fix is generated due to a failed consumption of IReplicationPacketData

Specified by:

applyFix in interface IReplicationPacketDataConsumer<IExecutableReplicationPacketData<?>>

data - data to fix

fix - fix to apply

Returns:

fixed data

Throws:

Exception

toFilterEntries

public Iterable<IReplicationFilterEntry> toFilterEntries(IReplicationInContext context,
                                                         IReplicationPacketData<?> data)

Description copied from interface: IReplicationPacketDataConsumer

Transform generated data to filter entry in order to be passed to a filter

Specified by:

toFilterEntries in interface IReplicationPacketDataConsumer<IExecutableReplicationPacketData<?>>

Returns:

collection of replication filter entries representing the data

extractParticipantsMetadata

public IReplicationParticipantsMetadata extractParticipantsMetadata(IReplicationPacketData<?> data)

Description copied from interface: IReplicationPacketDataConsumer

Extracts participants meta data for the provided replication packet data

Specified by:

extractParticipantsMetadata in interface IReplicationPacketDataConsumer<IExecutableReplicationPacketData<?>>

merge

public IReplicationPacketData<?> merge(IReplicationPacketData<?>[] allParticipantsData,
                                       IReplicationParticipantsMetadata participantsMetadata)

Description copied from interface: IReplicationPacketDataConsumer

Merges data of multiple participants operations to a single operation data which will eventually be executed as one.

Specified by:

merge in interface IReplicationPacketDataConsumer<IExecutableReplicationPacketData<?>>

participantsMetadata - TODO

consumePendingPackets

public IDataConsumeResult consumePendingPackets(IReplicationInBatchContext context,
                                                IReplicationInFacade replicationInFacade)

Description copied from interface: IReplicationPacketDataBatchConsumer

Consume packets which are pending in the provided batch context.

Specified by:

consumePendingPackets in interface IReplicationPacketDataBatchConsumer<IExecutableReplicationPacketData<?>>

getTypeManager

public SpaceTypeManager getTypeManager()

Specified by:

getTypeManager in interface IReplicationPacketDataConsumer<IExecutableReplicationPacketData<?>>