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

Class BlobstoreReplicationPacketDataProducer

java.lang.Object

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

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

All Implemented Interfaces:

IReplicationPacketDataProducer<IExecutableReplicationPacketData<?>>, IReplicationPacketEntryDataContentExtractor

public class BlobstoreReplicationPacketDataProducer
extends ReplicationPacketDataProducer

Since:

11.0.0 Wraps replication packets with blobstore bulk id when needed before sending them to replication

Author:

Boris

Constructor Summary

Constructors

Constructor and Description
BlobstoreReplicationPacketDataProducer(SpaceEngine spaceEngine, boolean replicateToTargetWithExternalDatasource, boolean replicateFullTake, ReplicationPacketDataMediator packetDataMediator)

Method Summary

Modifier and Type	Method and Description
IExecutableReplicationPacketData<?>	createSingleOperationData(IEntryHolder entryHolder, ReplicationSingleOperationType operationType, ReplicationOutContext replicationOutContext) Convert a single entry operation to a representing IReplicationPacketData

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

completePacketDataContent, convertData, convertEntryData, convertSingleEntryData, createEmptyMultipleEntryData, createFix, createFixForUnknownError, createGenericOperationData, createTransactionOperationData, getCustomContent, getMainEntryData, getMainTypeName, getSecondaryEntryData, requiresConversion, setSerializeWithFullContent, toFilterEntries

Methods inherited from class java.lang.Object

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

Constructor Detail

BlobstoreReplicationPacketDataProducer

public BlobstoreReplicationPacketDataProducer(SpaceEngine spaceEngine,
                                              boolean replicateToTargetWithExternalDatasource,
                                              boolean replicateFullTake,
                                              ReplicationPacketDataMediator packetDataMediator)

Method Detail

createSingleOperationData

public IExecutableReplicationPacketData<?> createSingleOperationData(IEntryHolder entryHolder,
                                                                     ReplicationSingleOperationType operationType,
                                                                     ReplicationOutContext replicationOutContext)

Description copied from interface: IReplicationPacketDataProducer

Convert a single entry operation to a representing IReplicationPacketData

Specified by:

createSingleOperationData in interface IReplicationPacketDataProducer<IExecutableReplicationPacketData<?>>

Overrides:

createSingleOperationData in class ReplicationPacketDataProducer

Parameters:

entryHolder - operation entry

operationType - operation type

Returns:

representing IReplicationPacketData