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, Map<String,WanReplicationEndpoint> endpoints)

Method Summary

Modifier and Type	Method and Description
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.
WanReplicationEndpoint	getEndpoint(String groupName) Returns the WanReplicationEndpoint with the groupName 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,
                                       Map<String,WanReplicationEndpoint> endpoints)

Method Detail

getEndpoints

public Collection<WanReplicationEndpoint> getEndpoints()

Returns all WanReplicationEndpoints for this delegate

getEndpoint

public WanReplicationEndpoint getEndpoint(String groupName)

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

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