com.gigaspaces.internal.cluster.node.impl.view

Class ViewReplicationChannelDataFilter

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.view.ViewReplicationChannelDataFilter

All Implemented Interfaces:

IReplicationChannelDataFilter

public class ViewReplicationChannelDataFilter
extends ReliableAsyncChannelDataFilter

Since:

8.0.5

Author:

Niv

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
ViewReplicationChannelDataFilter(CacheManager cacheManager, String groupName, ITemplatePacket[] templates, RegexCache regexCache, SpaceTypeManager typeManager)

Method Summary

Modifier and Type	Method and Description
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
protected void	finalize()
Object[]	getConstructionArgument()
static boolean	hasCreatedFilters(String groupName)

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

filterBeforeReplicatingData

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

filterAfterReplicatedEntryData, filterBeforeReplicatingEntryDataHasSideEffects

Methods inherited from class java.lang.Object

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

Constructor Detail

ViewReplicationChannelDataFilter

public ViewReplicationChannelDataFilter(CacheManager cacheManager,
                                        String groupName,
                                        ITemplatePacket[] templates,
                                        RegexCache regexCache,
                                        SpaceTypeManager typeManager)

Method Detail

hasCreatedFilters

public static boolean hasCreatedFilters(String groupName)

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

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

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)