public class DefaultEntryEventFilteringStrategy extends AbstractFilteringStrategy
UPDATEDevents, the predicate is evaluated against the new value; if the new value matches the predicate, then the
UPDATEDevent 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
|Constructor and Description|
|Modifier and Type||Method and Description|
Main entry point for filtering events according to given filter.
evaluateQueryEventFilter, getThisNodesAddress, processEntryEventFilter
public int doFilter(EventFilter filter, Data dataKey, Object oldValue, Object dataValue, EntryEventType eventType, String mapNameOrNull)
filter- the event filter
dataKey- the event entry key
oldValue- 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)
FilteringStrategy.FILTER_DOES_NOT_MATCHif 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.
IllegalArgumentException- if the provided
filteris not of a known type
public EntryEventDataCache getEntryEventDataCache()
EntryEventDataCacheimplementation to be used with this filtering strategy
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.