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 MapServiceContext	mapServiceContext
protected NodeEngine	nodeEngine
protected SerializationService	serializationService

Constructor Summary

Constructors

Constructor and Description
MapEventPublisherImpl(MapServiceContext mapServiceContext)

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	doFilter(EventFilter filter, Data dataKey, Object dataOldValue, Object dataValue, EntryEventType eventType, String mapNameOrNull)
protected List<EventRegistration>	getOrCreateList(List<EventRegistration> registrations)
protected Collection<EventRegistration>	getRegistrations(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 boolean	isIncludeValue(EventFilter filter)
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

mapServiceContext

protected final MapServiceContext mapServiceContext

nodeEngine

protected final NodeEngine nodeEngine

serializationService

protected final SerializationService serializationService

eventService

protected final EventService eventService

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

getOrCreateList

protected List<EventRegistration> getOrCreateList(List<EventRegistration> registrations)

doFilter

protected boolean doFilter(EventFilter filter,
               Data dataKey,
               Object dataOldValue,
               Object dataValue,
               EntryEventType eventType,
               String mapNameOrNull)

isIncludeValue

protected boolean isIncludeValue(EventFilter filter)

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

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)