public class MapEventPublisherImpl extends Object implements MapEventPublisher
Modifier and Type | Field and Description |
---|---|
protected EventService |
eventService |
protected MapServiceContext |
mapServiceContext |
protected NodeEngine |
nodeEngine |
protected SerializationService |
serializationService |
Constructor and Description |
---|
MapEventPublisherImpl(MapServiceContext mapServiceContext) |
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) |
protected final MapServiceContext mapServiceContext
protected final NodeEngine nodeEngine
protected final SerializationService serializationService
protected final EventService eventService
public MapEventPublisherImpl(MapServiceContext mapServiceContext)
public void publishWanReplicationUpdate(String mapName, EntryView entryView)
publishWanReplicationUpdate
in interface MapEventPublisher
public void publishWanReplicationRemove(String mapName, Data key, long removeTime)
publishWanReplicationRemove
in interface MapEventPublisher
public void publishWanReplicationUpdateBackup(String mapName, EntryView entryView)
publishWanReplicationUpdateBackup
in interface MapEventPublisher
public void publishWanReplicationRemoveBackup(String mapName, Data key, long removeTime)
publishWanReplicationRemoveBackup
in interface MapEventPublisher
public void publishMapEvent(Address caller, String mapName, EntryEventType eventType, int numberOfEntriesAffected)
publishMapEvent
in interface MapEventPublisher
public void publishEvent(Address caller, String mapName, EntryEventType eventType, Data dataKey, Object dataOldValue, Object dataValue)
publishEvent
in interface MapEventPublisher
public void publishEvent(Address caller, String mapName, EntryEventType eventType, Data dataKey, Object oldValue, Object value, Object mergingValue)
publishEvent
in interface MapEventPublisher
protected List<EventRegistration> getOrCreateList(List<EventRegistration> registrations)
protected boolean doFilter(EventFilter filter, Data dataKey, Object dataOldValue, Object dataValue, EntryEventType eventType, String mapNameOrNull)
protected boolean isIncludeValue(EventFilter filter)
public void publishMapPartitionLostEvent(Address caller, String mapName, int partitionId)
publishMapPartitionLostEvent
in interface MapEventPublisher
public void hintMapEvent(Address caller, String mapName, EntryEventType eventType, int numberOfEntriesAffected, int partitionId)
MapEventPublisher
hintMapEvent
in interface MapEventPublisher
protected Collection<EventRegistration> getRegistrations(String mapName)
protected void publishEventInternal(Collection<EventRegistration> registrations, Object eventData, int orderKey)
protected void publishWanReplicationEventInternal(String mapName, ReplicationEventObject event)
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.