com.hazelcast.map.impl.event

Class EnterpriseMapEventPublisherImpl

java.lang.Object

com.hazelcast.map.impl.event.MapEventPublisherImpl

com.hazelcast.map.impl.event.EnterpriseMapEventPublisherImpl

All Implemented Interfaces:

com.hazelcast.map.impl.event.MapEventPublisher

public class EnterpriseMapEventPublisherImpl
extends com.hazelcast.map.impl.event.MapEventPublisherImpl

Enterprise version of MapEventPublisher helper functionality.

Field Summary

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

eventService, filteringStrategy, LISTENER_WITH_PREDICATE_PRODUCES_NATURAL_EVENT_TYPES, mapServiceContext, nodeEngine, partitionService, PROP_LISTENER_WITH_PREDICATE_PRODUCES_NATURAL_EVENT_TYPES, queryCacheEventPublisher, serializationService

Constructor Summary

Constructors

Constructor and Description
EnterpriseMapEventPublisherImpl(EnterpriseMapServiceContext mapServiceContext)

Method Summary

Modifier and Type	Method and Description
void	publishEvent(com.hazelcast.nio.Address caller, String mapName, com.hazelcast.core.EntryEventType eventType, com.hazelcast.nio.serialization.Data dataKey, Object oldValue, Object value, Object mergingValue) If the in-memory format for this map is InMemoryFormat.NATIVE it will copy the values on-heap before publishing the event.
void	publishWanRemove(String mapName, com.hazelcast.nio.serialization.Data key) Additionally filters events and publishes only events that do not match the MapWanEventFilter configured for this map.
void	publishWanUpdate(String mapName, com.hazelcast.core.EntryView<com.hazelcast.nio.serialization.Data,com.hazelcast.nio.serialization.Data> entryView, boolean hasLoadProvenance) Additionally filters events and publishes only events that do not match the MapWanEventFilter configured for this map.

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

addEventToQueryCache, getRegistrations, hasEventListener, hintMapEvent, postPublishEvent, publishEvent, publishEventInternal, publishMapEvent, publishMapPartitionLostEvent, publishWanEvent

Methods inherited from class java.lang.Object

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

Constructor Detail

EnterpriseMapEventPublisherImpl

public EnterpriseMapEventPublisherImpl(EnterpriseMapServiceContext mapServiceContext)

Method Detail

publishEvent

public void publishEvent(com.hazelcast.nio.Address caller,
                         String mapName,
                         com.hazelcast.core.EntryEventType eventType,
                         com.hazelcast.nio.serialization.Data dataKey,
                         Object oldValue,
                         Object value,
                         Object mergingValue)

If the in-memory format for this map is InMemoryFormat.NATIVE it will copy the values on-heap before publishing the event.

Specified by:

publishEvent in interface com.hazelcast.map.impl.event.MapEventPublisher

Overrides:

publishEvent in class com.hazelcast.map.impl.event.MapEventPublisherImpl

publishWanUpdate

public void publishWanUpdate(String mapName,
                             com.hazelcast.core.EntryView<com.hazelcast.nio.serialization.Data,com.hazelcast.nio.serialization.Data> entryView,
                             boolean hasLoadProvenance)

Additionally filters events and publishes only events that do not match the MapWanEventFilter configured for this map.

Specified by:

publishWanUpdate in interface com.hazelcast.map.impl.event.MapEventPublisher

Overrides:

publishWanUpdate in class com.hazelcast.map.impl.event.MapEventPublisherImpl

Parameters:

mapName - the map name

entryView - the updated entry

publishWanRemove

public void publishWanRemove(String mapName,
                             com.hazelcast.nio.serialization.Data key)

Additionally filters events and publishes only events that do not match the MapWanEventFilter configured for this map.

Specified by:

publishWanRemove in interface com.hazelcast.map.impl.event.MapEventPublisher

Overrides:

publishWanRemove in class com.hazelcast.map.impl.event.MapEventPublisherImpl

Parameters:

mapName - the map name

key - the key of the removed entry