com.hazelcast.map.impl.event

Class DefaultEntryEventFilteringStrategy

java.lang.Object

com.hazelcast.map.impl.event.AbstractFilteringStrategy

com.hazelcast.map.impl.event.DefaultEntryEventFilteringStrategy

All Implemented Interfaces:

FilteringStrategy

public class DefaultEntryEventFilteringStrategy
extends AbstractFilteringStrategy

This entry event filtering strategy models the default backwards compatible Hazelcast behaviour. In particular, when processing UPDATED events, the predicate is evaluated against the new value; if the new value matches the predicate, then the UPDATED event will be published to the registered listeners.

Note that when trying to build a continuous query cache, this filtering strategy is flawed, as the listener will not be notified for updated entries whose old value matched the predicate while new value does not match the predicate. This has been addressed in QueryCacheNaturalFilteringStrategy.

See Also:

QueryCacheNaturalFilteringStrategy

Field Summary

Fields inherited from class com.hazelcast.map.impl.event.AbstractFilteringStrategy

mapServiceContext, serializationService

Fields inherited from interface com.hazelcast.map.impl.event.FilteringStrategy

FILTER_DOES_NOT_MATCH

Constructor Summary

Constructors

Constructor and Description
DefaultEntryEventFilteringStrategy(SerializationService serializationService, MapServiceContext mapServiceContext)

Method Summary

Modifier and Type	Method and Description
int	doFilter(EventFilter filter, Data dataKey, Object dataOldValue, Object dataValue, EntryEventType eventType, String mapNameOrNull) Main entry point for filtering events according to given filter.
EntryEventDataCache	getEntryEventDataCache()
String	toString()

Methods inherited from class com.hazelcast.map.impl.event.AbstractFilteringStrategy

evaluateQueryEventFilter, getThisNodesAddress, processEntryEventFilter

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultEntryEventFilteringStrategy

public DefaultEntryEventFilteringStrategy(SerializationService serializationService,
                                          MapServiceContext mapServiceContext)

Method Detail

doFilter

public int doFilter(EventFilter filter,
                    Data dataKey,
                    Object dataOldValue,
                    Object dataValue,
                    EntryEventType eventType,
                    String mapNameOrNull)

Main entry point for filtering events according to given filter.

Parameters:

filter - the event filter

dataKey - the event entry key

dataOldValue - the old value of the event entry

dataValue - the new value of the event entry

eventType - the event type

mapNameOrNull - the map name. May be null if this is not a map event (e.g. cache event)

Returns:

FilteringStrategy.FILTER_DOES_NOT_MATCH if the event does not match the filter, otherwise the integer event type of the event to be published. This allows a filtering strategy to alter the type of event that is actually published, depending on the attributes of the individual event registration.

Throws:

IllegalArgumentException - if the provided filter is not of a known type

getEntryEventDataCache

public EntryEventDataCache getEntryEventDataCache()

Returns:

a new instance of EntryEventDataCache implementation to be used with this filtering strategy

toString

public String toString()

Overrides:

toString in class Object