com.hazelcast.enterprise.wan

Class WanReplicationPublisherDelegate

java.lang.Object

com.hazelcast.enterprise.wan.WanReplicationPublisherDelegate

All Implemented Interfaces:

com.hazelcast.wan.WanReplicationPublisher

public final class WanReplicationPublisherDelegate
extends Object
implements com.hazelcast.wan.WanReplicationPublisher

Delegating WAN replication publisher implementation. This implementation is a container for multiple WAN publisher endpoints. When publishing an event on this delegate, all endpoints are notified.

Constructor Summary

Constructors

Constructor and Description
WanReplicationPublisherDelegate(String name, ConcurrentMap<String,WanReplicationEndpoint> endpoints)

Method Summary

Modifier and Type	Method and Description
void	addEndpoint(String publisherId, WanReplicationEndpoint endpoint)
void	checkWanReplicationQueues()
void	collectAllServiceNamespaces(com.hazelcast.spi.PartitionReplicationEvent event, Set<com.hazelcast.spi.ServiceNamespace> namespaces) Collect the namespaces of all queues that should be replicated by the replication event.
void	collectReplicationData(com.hazelcast.spi.PartitionReplicationEvent event, Collection<com.hazelcast.spi.ServiceNamespace> namespaces, EWRMigrationContainer migrationDataContainer) Collect all replication data matching the replication event and collection of namespaces being replicated.
void	destroyMapData(String mapName) Releases all resources for the map with the given mapName.
WanReplicationEndpoint	getEndpoint(String publisherId) Returns the WanReplicationEndpoint with the publisherId or null if it doesn't exist.
Collection<WanReplicationEndpoint>	getEndpoints() Returns all WanReplicationEndpoints for this delegate
String	getName()
Map<String,com.hazelcast.monitor.LocalWanPublisherStats>	getStats()
void	publishReplicationEvent(String serviceName, com.hazelcast.wan.ReplicationEventObject eventObject) Publishes a replication event to all endpoints to which this publisher delegates.
void	publishReplicationEvent(com.hazelcast.wan.WanReplicationEvent wanReplicationEvent) Publishes a replication event to all endpoints to which this publisher delegates.
void	publishReplicationEventBackup(String serviceName, com.hazelcast.wan.ReplicationEventObject eventObject) Publishes a backup replication event to all endpoints 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

WanReplicationPublisherDelegate

public WanReplicationPublisherDelegate(String name,
                                       ConcurrentMap<String,WanReplicationEndpoint> endpoints)

Method Detail

getEndpoints

public Collection<WanReplicationEndpoint> getEndpoints()

Returns all WanReplicationEndpoints for this delegate

getEndpoint

public WanReplicationEndpoint getEndpoint(String publisherId)

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

addEndpoint

public void addEndpoint(String publisherId,
                        WanReplicationEndpoint endpoint)

getName

public String getName()

publishReplicationEvent

public void publishReplicationEvent(String serviceName,
                                    com.hazelcast.wan.ReplicationEventObject eventObject)

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

Specified by:

publishReplicationEvent in interface com.hazelcast.wan.WanReplicationPublisher

publishReplicationEventBackup

public void publishReplicationEventBackup(String serviceName,
                                          com.hazelcast.wan.ReplicationEventObject eventObject)

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

Specified by:

publishReplicationEventBackup in interface com.hazelcast.wan.WanReplicationPublisher

publishReplicationEvent

public void publishReplicationEvent(com.hazelcast.wan.WanReplicationEvent wanReplicationEvent)

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

Specified by:

publishReplicationEvent in interface com.hazelcast.wan.WanReplicationPublisher

getStats

public Map<String,com.hazelcast.monitor.LocalWanPublisherStats> getStats()

checkWanReplicationQueues

public void checkWanReplicationQueues()

Specified by:

checkWanReplicationQueues in interface com.hazelcast.wan.WanReplicationPublisher

collectReplicationData

public void collectReplicationData(com.hazelcast.spi.PartitionReplicationEvent event,
                                   Collection<com.hazelcast.spi.ServiceNamespace> namespaces,
                                   EWRMigrationContainer migrationDataContainer)

Collect all replication data matching the replication event and collection of namespaces being replicated.

Parameters:

event - the replication event

namespaces - the object namespaces which are being replicated

migrationDataContainer - the container for the migration data

collectAllServiceNamespaces

public void collectAllServiceNamespaces(com.hazelcast.spi.PartitionReplicationEvent event,
                                        Set<com.hazelcast.spi.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