public interface InternalWanReplicationPublisher<T> extends WanReplicationPublisher<T>
Modifier and Type | Method and Description |
---|---|
void |
destroyMapData(String mapName)
Releases all resources for the map with the given
mapName . |
int |
removeWanEvents(int partitionId,
String serviceName,
String objectName,
int count)
Removes a
count number of events pending replication and belonging
to the provided service, object and partition. |
collectAllServiceNamespaces, doPrepublicationChecks, getStats, init, pause, prepareEventContainerReplicationData, processEventContainerReplicationData, publishAntiEntropyEvent, publishReplicationEvent, publishReplicationEventBackup, removeWanEvents, removeWanEvents, republishReplicationEvent, reset, resume, shutdown, stop
void destroyMapData(String mapName)
mapName
.mapName
- the map nameint removeWanEvents(int partitionId, String serviceName, String objectName, int count)
count
number of events pending replication and belonging
to the provided service, object and partition.
If the publisher does not store WAN events, this method is a no-op.
NOTE: used only in Hazelcast Enterprise.serviceName
- the service name of the WAN events should be removedobjectName
- the object name of the WAN events should be removedpartitionId
- the partition ID of the WAN events should be removedcount
- the number of events to removeCopyright © 2019 Hazelcast, Inc.. All rights reserved.