com.gigaspaces.internal.cluster.node.impl.groups.reliableasync

Class GatewayChannelDataFilter

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.groups.AbstractReplicationChannelDataFilter

com.gigaspaces.internal.cluster.node.impl.groups.reliableasync.ReliableAsyncChannelDataFilter

com.gigaspaces.internal.cluster.node.impl.groups.reliableasync.GatewayChannelDataFilter

All Implemented Interfaces:

IReplicationChannelDataFilter

public class GatewayChannelDataFilter
extends ReliableAsyncChannelDataFilter

Nested Class Summary

Nested classes/interfaces inherited from interface com.gigaspaces.internal.cluster.node.impl.groups.IReplicationChannelDataFilter

IReplicationChannelDataFilter.FilterOperation

Constructor Summary

Constructors

Constructor and Description
GatewayChannelDataFilter(boolean replicateChangeAsUpdate)

Method Summary

Modifier and Type	Method and Description
ReplicationChannelDataFilterResult	filterBeforeReplicatingData(IReplicationPacketData<?> data, PlatformLogicalVersion targetLogicalVersion, Logger contextLogger) Specifies whether the given data should pass the filter as is, be converted or removed
ReplicationChannelEntryDataFilterResult	filterBeforeReplicatingEntryData(IReplicationPacketEntryData entryData, PlatformLogicalVersion targetLogicalVersion, IReplicationPacketEntryDataContentExtractor contentExtractor, Logger contextLogger, IReplicationPacketData data) Specifies whether the given entry data should pass the filter as is, be converted or removed
boolean	filterBeforeReplicatingUnreliableOperation(IReplicationUnreliableOperation operation, PlatformLogicalVersion targetLogicalVersion) Specifies whether the given unreliable operation should pass the filter and not be removed
Object[]	getConstructionArgument()

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.groups.AbstractReplicationChannelDataFilter

filterAfterReplicatedEntryData, filterBeforeReplicatingEntryDataHasSideEffects

Methods inherited from class java.lang.Object

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

Constructor Detail

GatewayChannelDataFilter

public GatewayChannelDataFilter(boolean replicateChangeAsUpdate)

Method Detail

filterBeforeReplicatingEntryData

public ReplicationChannelEntryDataFilterResult filterBeforeReplicatingEntryData(IReplicationPacketEntryData entryData,
                                                                                PlatformLogicalVersion targetLogicalVersion,
                                                                                IReplicationPacketEntryDataContentExtractor contentExtractor,
                                                                                Logger contextLogger,
                                                                                IReplicationPacketData data)

Description copied from interface: IReplicationChannelDataFilter

Specifies whether the given entry data should pass the filter as is, be converted or removed

targetLogicalVersion - The logical version of the target

contentExtractor - extracts content from the data

contextLogger - context Logger

filterBeforeReplicatingData

public ReplicationChannelDataFilterResult filterBeforeReplicatingData(IReplicationPacketData<?> data,
                                                                      PlatformLogicalVersion targetLogicalVersion,
                                                                      Logger contextLogger)

Description copied from interface: IReplicationChannelDataFilter

Specifies whether the given data should pass the filter as is, be converted or removed

Specified by:

filterBeforeReplicatingData in interface IReplicationChannelDataFilter

Overrides:

filterBeforeReplicatingData in class ReliableAsyncChannelDataFilter

targetLogicalVersion - The logical version of the target

contextLogger - context Logger

filterBeforeReplicatingUnreliableOperation

public boolean filterBeforeReplicatingUnreliableOperation(IReplicationUnreliableOperation operation,
                                                          PlatformLogicalVersion targetLogicalVersion)

Description copied from interface: IReplicationChannelDataFilter

Specifies whether the given unreliable operation should pass the filter and not be removed

targetLogicalVersion - The logical version of the target

Returns:

true if the unreliable operation should not be filtered, false otherwise

getConstructionArgument

public Object[] getConstructionArgument()

Returns:

construction argument that are used in order to duplicate this filter instance using a IReplicationChannelDataFilterBuilder this is generally used when serializing the filter between replication members (reliable async)