com.gigaspaces.internal.cluster.node.impl.notification

Class NotificationReplicationChannelDataFilter

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.notification.NotificationReplicationChannelDataFilter

All Implemented Interfaces:

IReplicationChannelDataFilter

public class NotificationReplicationChannelDataFilter
extends ReliableAsyncChannelDataFilter

Since:

9.0

Author:

Dan Kilman

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NotificationReplicationChannelDataFilter.DurableNotificationConversionFlags

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

IReplicationChannelDataFilter.FilterOperation

Constructor Summary

Constructors

Constructor and Description
NotificationReplicationChannelDataFilter(CacheManager cacheManager, String groupName, RegexCache regexCache, SpaceTypeManager typeManager, FilterManager filterManager, NotifyTemplateHolder tHolder)

Method Summary

Modifier and Type	Method and Description
TemplateInfo	createTemplateInfo()
void	filterAfterReplicatedEntryData(IReplicationPacketEntryData data, PlatformLogicalVersion targetLogicalVersion, IReplicationPacketEntryDataContentExtractor contentExtractor, Logger contextLogger) Called after entry data was replicated successfully
ReplicationChannelEntryDataFilterResult	filterBeforeReplicatingEntryData(IReplicationPacketEntryData packetEntryData, 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	filterBeforeReplicatingEntryDataHasSideEffects() Specifies wheter the filter operations have a side effect and cannot be called more than once for the same entry data
boolean	filterBeforeReplicatingUnreliableOperation(IReplicationUnreliableOperation operation, PlatformLogicalVersion targetLogicalVersion) Specifies whether the given unreliable operation should pass the filter and not be removed
Object[]	getConstructionArgument()
NotifyTemplateHolder	getNotifyTemplateHolder()
IServerTypeDesc	getTemplateTypeDesc()
void	initTemplate()
boolean	isTemplateOfType(String typeName)

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

filterBeforeReplicatingData

Methods inherited from class java.lang.Object

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

Constructor Detail

NotificationReplicationChannelDataFilter

public NotificationReplicationChannelDataFilter(CacheManager cacheManager,
                                                String groupName,
                                                RegexCache regexCache,
                                                SpaceTypeManager typeManager,
                                                FilterManager filterManager,
                                                NotifyTemplateHolder tHolder)

Method Detail

getTemplateTypeDesc

public IServerTypeDesc getTemplateTypeDesc()

isTemplateOfType

public boolean isTemplateOfType(String typeName)

createTemplateInfo

public TemplateInfo createTemplateInfo()

filterBeforeReplicatingEntryData

public ReplicationChannelEntryDataFilterResult filterBeforeReplicatingEntryData(IReplicationPacketEntryData packetEntryData,
                                                                                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

initTemplate

public void initTemplate()

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

filterAfterReplicatedEntryData

public void filterAfterReplicatedEntryData(IReplicationPacketEntryData data,
                                           PlatformLogicalVersion targetLogicalVersion,
                                           IReplicationPacketEntryDataContentExtractor contentExtractor,
                                           Logger contextLogger)

Description copied from interface: IReplicationChannelDataFilter

Called after entry data was replicated successfully

Specified by:

filterAfterReplicatedEntryData in interface IReplicationChannelDataFilter

Overrides:

filterAfterReplicatedEntryData in class AbstractReplicationChannelDataFilter

targetLogicalVersion - The logical version of the target

contentExtractor - extracts content from the data

contextLogger - context Logger

filterBeforeReplicatingEntryDataHasSideEffects

public boolean filterBeforeReplicatingEntryDataHasSideEffects()

Description copied from interface: IReplicationChannelDataFilter

Specifies wheter the filter operations have a side effect and cannot be called more than once for the same entry data

Specified by:

filterBeforeReplicatingEntryDataHasSideEffects in interface IReplicationChannelDataFilter

Overrides:

filterBeforeReplicatingEntryDataHasSideEffects in class AbstractReplicationChannelDataFilter

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)

getNotifyTemplateHolder

public NotifyTemplateHolder getNotifyTemplateHolder()