public final class DelegatingWanReplicationScheme extends Object
Constructor and Description |
---|
DelegatingWanReplicationScheme(String name,
ConcurrentMap<String,WanReplicationPublisher> publishers) |
Modifier and Type | Method and Description |
---|---|
void |
addPublisher(String publisherId,
WanReplicationPublisher publisher) |
void |
collectAllServiceNamespaces(PartitionReplicationEvent event,
Set<ServiceNamespace> namespaces)
Collect the namespaces of all queues that should be replicated by the
replication event.
|
void |
destroyMapData(String mapName)
Releases all resources for the map with the given
mapName . |
void |
doPrepublicationChecks() |
String |
getName() |
WanReplicationPublisher |
getPublisher(String publisherId)
|
Collection<WanReplicationPublisher> |
getPublishers()
Returns all
WanReplicationPublisher s for this delegate |
Map<String,LocalWanPublisherStats> |
getStats() |
Map<String,Object> |
prepareEventContainerReplicationData(PartitionReplicationEvent event,
Collection<ServiceNamespace> namespaces)
Collect all replication data matching the replication event and collection
of namespaces being replicated.
|
void |
publishReplicationEvent(WanReplicationEvent event)
Publishes a replication event to all publishers to which this publisher
delegates.
|
void |
publishReplicationEventBackup(WanReplicationEvent event)
Publishes a backup replication event to all publishers to which this
publisher delegates.
|
void |
republishReplicationEvent(WanReplicationEvent wanReplicationEvent)
Publishes a replication event to all publishers to which this publisher
delegates.
|
public DelegatingWanReplicationScheme(@Nonnull String name, @Nonnull ConcurrentMap<String,WanReplicationPublisher> publishers)
@Nonnull public Collection<WanReplicationPublisher> getPublishers()
WanReplicationPublisher
s for this delegatepublic WanReplicationPublisher getPublisher(String publisherId)
public void addPublisher(@Nonnull String publisherId, @Nonnull WanReplicationPublisher publisher)
public String getName()
public void publishReplicationEvent(WanReplicationEvent event)
public void publishReplicationEventBackup(WanReplicationEvent event)
public void republishReplicationEvent(WanReplicationEvent wanReplicationEvent)
public Map<String,LocalWanPublisherStats> getStats()
public void doPrepublicationChecks()
public Map<String,Object> prepareEventContainerReplicationData(PartitionReplicationEvent event, Collection<ServiceNamespace> namespaces)
event
- the replication eventnamespaces
- the object namespaces which are being replicatedpublic void collectAllServiceNamespaces(PartitionReplicationEvent event, Set<ServiceNamespace> namespaces)
event
- the replication eventnamespaces
- the set in which namespaces should be addedpublic void destroyMapData(String mapName)
mapName
.mapName
- the map mapNameCopyright © 2019 Hazelcast, Inc.. All rights reserved.