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

Interface IReplicationPacketDataConsumer<T extends IReplicationPacketData<?>>

All Known Subinterfaces:

IReplicationPacketDataBatchConsumer<T>

All Known Implementing Classes:

BlobstoreReplicationPacketDataConsumer, ReplicationPacketDataConsumer

public interface IReplicationPacketDataConsumer<T extends IReplicationPacketData<?>>

Consumes IReplicationPacketData and delegate it to the corresponding replication in handler.

Since:

8.0

Author:

eitany

Method Summary

Modifier and Type	Method and Description
T	applyFix(IReplicationInContext context, T data, IDataConsumeFix fix) Apply a fix to a data, the fix is generated due to a failed consumption of IReplicationPacketData
IDataConsumeResult	consume(IReplicationInContext context, T data, IReplicationInFacade replicationInFacade, IReplicationInFilterCallback filterInCallback) Consumes a IReplicationPacketData and delegate the operation is represents to the corresponding method at the given IReplicationInFacade
IReplicationParticipantsMetadata	extractParticipantsMetadata(IReplicationPacketData<?> data) Extracts participants meta data for the provided replication packet data
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

Method Detail

consume

IDataConsumeResult consume(IReplicationInContext context,
                           T data,
                           IReplicationInFacade replicationInFacade,
                           IReplicationInFilterCallback filterInCallback)

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

Parameters:

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

T applyFix(IReplicationInContext context,
           T data,
           IDataConsumeFix fix)
    throws Exception

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

Parameters:

data - data to fix

fix - fix to apply

Returns:

fixed data

Throws:

Exception

toFilterEntries

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

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

Returns:

collection of replication filter entries representing the data

extractParticipantsMetadata

IReplicationParticipantsMetadata extractParticipantsMetadata(IReplicationPacketData<?> data)

Extracts participants meta data for the provided replication packet data

merge

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

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

Parameters:

participantsMetadata - TODO