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, queryCacheEventPublisher, serializationService

Constructor Summary

Constructors

Constructor and Description
EnterpriseMapEventPublisherImpl(EnterpriseMapServiceContext mapServiceContext)

Method Summary

Modifier and Type	Method and Description
EnterpriseMapServiceContext	getEnterpriseMapServiceContext()
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	publishWanReplicationRemove(String mapName, com.hazelcast.nio.serialization.Data key, long removeTime) Additionally filters events and publishes only events that do not match the MapWanEventFilter configured for this map.
void	publishWanReplicationRemoveBackup(String mapName, com.hazelcast.nio.serialization.Data key, long removeTime) Additionally filters events and publishes only events that do not match the MapWanEventFilter configured for this map.
void	publishWanReplicationUpdate(String mapName, com.hazelcast.core.EntryView<com.hazelcast.nio.serialization.Data,com.hazelcast.nio.serialization.Data> entryView) Additionally filters events and publishes only events that do not match the MapWanEventFilter configured for this map.
void	publishWanReplicationUpdateBackup(String mapName, com.hazelcast.core.EntryView entryView) 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, publishWanReplicationEventInternal

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

publishWanReplicationUpdate

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

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

Specified by:

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

Overrides:

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

Parameters:

mapName - the map name

entryView - the updated entry

publishWanReplicationRemove

public void publishWanReplicationRemove(String mapName,
                                        com.hazelcast.nio.serialization.Data key,
                                        long removeTime)

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

Specified by:

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

Overrides:

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

Parameters:

mapName - the map name

key - the key of the removed entry

removeTime - the clock time for the remove event

publishWanReplicationUpdateBackup

public void publishWanReplicationUpdateBackup(String mapName,
                                              com.hazelcast.core.EntryView entryView)

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

Specified by:

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

Overrides:

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

Parameters:

mapName - the map name

entryView - the updated entry

publishWanReplicationRemoveBackup

public void publishWanReplicationRemoveBackup(String mapName,
                                              com.hazelcast.nio.serialization.Data key,
                                              long removeTime)

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

Specified by:

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

Overrides:

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

Parameters:

mapName - the map name

key - the key of the removed entry

removeTime - the clock time for the remove event

getEnterpriseMapServiceContext

public EnterpriseMapServiceContext getEnterpriseMapServiceContext()