com.hazelcast.wan.impl

Class DelegatingWanReplicationScheme

java.lang.Object

com.hazelcast.wan.impl.DelegatingWanReplicationScheme

public final class DelegatingWanReplicationScheme
extends Object

WAN replication scheme implementation delegating to multiple WAN replication publisher implementations. This implementation is a container for multiple WAN publishers. When publishing an event on this delegate, all publishers are notified.

Constructor Summary

Constructors

Constructor and Description
DelegatingWanReplicationScheme(String name, ConcurrentMap<String,WanReplicationPublisher> publishers)

Method Summary

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) Returns the WanReplicationPublisher with the publisherId or null if it doesn't exist.
Collection<WanReplicationPublisher>	getPublishers() Returns all WanReplicationPublishers 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.

Methods inherited from class java.lang.Object

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

Constructor Detail

DelegatingWanReplicationScheme

public DelegatingWanReplicationScheme(@Nonnull
                                      String name,
                                      @Nonnull
                                      ConcurrentMap<String,WanReplicationPublisher> publishers)

Method Detail

getPublishers

@Nonnull
public Collection<WanReplicationPublisher> getPublishers()

Returns all WanReplicationPublishers for this delegate

getPublisher

public WanReplicationPublisher getPublisher(String publisherId)

Returns the WanReplicationPublisher with the publisherId or null if it doesn't exist.

addPublisher

public void addPublisher(@Nonnull
                         String publisherId,
                         @Nonnull
                         WanReplicationPublisher publisher)

getName

public String getName()

publishReplicationEvent

public void publishReplicationEvent(WanReplicationEvent event)

Publishes a replication event to all publishers to which this publisher delegates.

publishReplicationEventBackup

public void publishReplicationEventBackup(WanReplicationEvent event)

Publishes a backup replication event to all publishers to which this publisher delegates.

republishReplicationEvent

public void republishReplicationEvent(WanReplicationEvent wanReplicationEvent)

Publishes a replication event to all publishers to which this publisher delegates.

getStats

public Map<String,LocalWanPublisherStats> getStats()

doPrepublicationChecks

public void doPrepublicationChecks()

prepareEventContainerReplicationData

public Map<String,Object> prepareEventContainerReplicationData(PartitionReplicationEvent event,
                                                               Collection<ServiceNamespace> namespaces)

Collect all replication data matching the replication event and collection of namespaces being replicated. Returns containers for WAN replication events grouped by WAN publisher ID.

Parameters:

event - the replication event

namespaces - the object namespaces which are being replicated

Returns:

a map from WAN publisher ID to container object for WAN replication events

collectAllServiceNamespaces

public void collectAllServiceNamespaces(PartitionReplicationEvent event,
                                        Set<ServiceNamespace> namespaces)

Collect the namespaces of all queues that should be replicated by the replication event.

Parameters:

event - the replication event

namespaces - the set in which namespaces should be added

destroyMapData

public void destroyMapData(String mapName)

Releases all resources for the map with the given mapName.

Parameters:

mapName - the map mapName