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

Class BlobstoreReplicationPacketDataConsumer

java.lang.Object

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

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

All Implemented Interfaces:

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

public class BlobstoreReplicationPacketDataConsumer
extends ReplicationPacketDataConsumer

Since:

11.0.0 Consumes packets and adds the proper information to replication context about whether the packet is part of blobstore bulk or not.

Author:

Boris

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.packets.data.ReplicationPacketDataConsumer

applyFix, consumePendingPackets, extractParticipantsMetadata, getTypeManager, merge, toFilterEntries

Methods inherited from class java.lang.Object

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

Constructor Detail

BlobstoreReplicationPacketDataConsumer

public BlobstoreReplicationPacketDataConsumer(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<?>>

Overrides:

consume in class ReplicationPacketDataConsumer

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