com.hazelcast.map.impl.event

Class MapEventPublisherImpl

java.lang.Object

com.hazelcast.map.impl.event.MapEventPublisherImpl

All Implemented Interfaces:

MapEventPublisher

public class MapEventPublisherImpl
extends Object
implements MapEventPublisher

Field Summary

Fields

Modifier and Type	Field and Description
protected EventService	eventService
protected FilteringStrategy	filteringStrategy
static HazelcastProperty	LISTENER_WITH_PREDICATE_PRODUCES_NATURAL_EVENT_TYPES When true, enables processing of entry events for listeners with predicates to fit with "query cache" concept: for example when the original event indicates an update from an old value that does not match the predicate to a new value that does match, then the entry listener will be notified with an ADDED event.
protected MapServiceContext	mapServiceContext
protected NodeEngine	nodeEngine
protected QueryCacheEventPublisher	queryCacheEventPublisher
protected SerializationService	serializationService

Constructor Summary

Constructors

Constructor and Description
MapEventPublisherImpl(MapServiceContext mapServiceContext)

Method Summary

Modifier and Type	Method and Description
void	addEventToQueryCache(Object eventData) Notifies QueryCache subscribers directly, without publishing an event to other map listeners.
protected Collection<EventRegistration>	getRegistrations(String mapName)
boolean	hasEventListener(String mapName)
void	hintMapEvent(Address caller, String mapName, EntryEventType eventType, int numberOfEntriesAffected, int partitionId) Only gives a hint which indicates that a map-wide operation has just been executed on this partition.
protected void	postPublishEvent(Collection<EntryEventData> eventDataIncludingValues, Collection<EntryEventData> eventDataExcludingValues) Hook for actions to perform after any of publishEvent methods is executed.
void	publishEvent(Address caller, String mapName, EntryEventType eventType, Data dataKey, Object dataOldValue, Object dataValue)
void	publishEvent(Address caller, String mapName, EntryEventType eventType, Data dataKey, Object oldValue, Object value, Object mergingValue)
protected void	publishEventInternal(Collection<EventRegistration> registrations, Object eventData, int orderKey)
void	publishMapEvent(Address caller, String mapName, EntryEventType eventType, int numberOfEntriesAffected)
void	publishMapPartitionLostEvent(Address caller, String mapName, int partitionId)
protected void	publishWanReplicationEventInternal(String mapName, ReplicationEventObject event)
void	publishWanReplicationRemove(String mapName, Data key, long removeTime)
void	publishWanReplicationRemoveBackup(String mapName, Data key, long removeTime)
void	publishWanReplicationUpdate(String mapName, EntryView entryView)
void	publishWanReplicationUpdateBackup(String mapName, EntryView entryView)

Methods inherited from class java.lang.Object

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

Field Detail

LISTENER_WITH_PREDICATE_PRODUCES_NATURAL_EVENT_TYPES

public static final HazelcastProperty LISTENER_WITH_PREDICATE_PRODUCES_NATURAL_EVENT_TYPES

When true, enables processing of entry events for listeners with predicates to fit with "query cache" concept: for example when the original event indicates an update from an old value that does not match the predicate to a new value that does match, then the entry listener will be notified with an ADDED event. This affects only map listeners with predicates and the way entry updates are handled. Put/remove operations are not affected, neither are listeners without predicates. Default value is false, to maintain compatible behavior with previous Hazelcast versions.

mapServiceContext

protected final MapServiceContext mapServiceContext

nodeEngine

protected final NodeEngine nodeEngine

serializationService

protected final SerializationService serializationService

eventService

protected final EventService eventService

filteringStrategy

protected final FilteringStrategy filteringStrategy

queryCacheEventPublisher

protected final QueryCacheEventPublisher queryCacheEventPublisher

Constructor Detail

MapEventPublisherImpl

public MapEventPublisherImpl(MapServiceContext mapServiceContext)

Method Detail

publishWanReplicationUpdate

public void publishWanReplicationUpdate(String mapName,
                                        EntryView entryView)

Specified by:

publishWanReplicationUpdate in interface MapEventPublisher

publishWanReplicationRemove

public void publishWanReplicationRemove(String mapName,
                                        Data key,
                                        long removeTime)

Specified by:

publishWanReplicationRemove in interface MapEventPublisher

publishWanReplicationUpdateBackup

public void publishWanReplicationUpdateBackup(String mapName,
                                              EntryView entryView)

Specified by:

publishWanReplicationUpdateBackup in interface MapEventPublisher

publishWanReplicationRemoveBackup

public void publishWanReplicationRemoveBackup(String mapName,
                                              Data key,
                                              long removeTime)

Specified by:

publishWanReplicationRemoveBackup in interface MapEventPublisher

publishMapEvent

public void publishMapEvent(Address caller,
                            String mapName,
                            EntryEventType eventType,
                            int numberOfEntriesAffected)

Specified by:

publishMapEvent in interface MapEventPublisher

publishEvent

public void publishEvent(Address caller,
                         String mapName,
                         EntryEventType eventType,
                         Data dataKey,
                         Object dataOldValue,
                         Object dataValue)

Specified by:

publishEvent in interface MapEventPublisher

publishEvent

public void publishEvent(Address caller,
                         String mapName,
                         EntryEventType eventType,
                         Data dataKey,
                         Object oldValue,
                         Object value,
                         Object mergingValue)

Specified by:

publishEvent in interface MapEventPublisher

postPublishEvent

protected void postPublishEvent(Collection<EntryEventData> eventDataIncludingValues,
                                Collection<EntryEventData> eventDataExcludingValues)

Hook for actions to perform after any of publishEvent methods is executed. This method will be invoked once per unique EntryEventData generated by publishEvent, regardless of the number of registrations on which the event is published.

Parameters:

eventDataIncludingValues -

eventDataExcludingValues -

publishMapPartitionLostEvent

public void publishMapPartitionLostEvent(Address caller,
                                         String mapName,
                                         int partitionId)

Specified by:

publishMapPartitionLostEvent in interface MapEventPublisher

hintMapEvent

public void hintMapEvent(Address caller,
                         String mapName,
                         EntryEventType eventType,
                         int numberOfEntriesAffected,
                         int partitionId)

Description copied from interface: MapEventPublisher

Only gives a hint which indicates that a map-wide operation has just been executed on this partition. This method should not publish an event.

Currently a map event is published by the end which calls map#clear or map#evictAll and there is not any order guarantee between events fired after map#put and map#clear, as a result of that, we may clear a put after a map#clear, to tackle with that kind of possible anomalies, this hint may be used under some conditions internally.

Specified by:

hintMapEvent in interface MapEventPublisher

addEventToQueryCache

public void addEventToQueryCache(Object eventData)

Description copied from interface: MapEventPublisher

Notifies QueryCache subscribers directly, without publishing an event to other map listeners. This is necessary in certain cases, such as when loading entries into a map.

Specified by:

addEventToQueryCache in interface MapEventPublisher

Parameters:

eventData - the event to publish to query caches

hasEventListener

public boolean hasEventListener(String mapName)

Specified by:

hasEventListener in interface MapEventPublisher

getRegistrations

protected Collection<EventRegistration> getRegistrations(String mapName)

publishEventInternal

protected void publishEventInternal(Collection<EventRegistration> registrations,
                                    Object eventData,
                                    int orderKey)

publishWanReplicationEventInternal

protected void publishWanReplicationEventInternal(String mapName,
                                                  ReplicationEventObject event)