com.hazelcast.enterprise.wan

Class EnterpriseWanReplicationService

java.lang.Object

com.hazelcast.enterprise.wan.EnterpriseWanReplicationService

All Implemented Interfaces:

com.hazelcast.spi.CoreService, com.hazelcast.spi.FragmentedMigrationAwareService, com.hazelcast.spi.LiveOperationsTracker, com.hazelcast.spi.MigrationAwareService, com.hazelcast.spi.PostJoinAwareService, com.hazelcast.spi.StatisticsAwareService<com.hazelcast.monitor.LocalWanStats>, com.hazelcast.wan.WanReplicationService

public class EnterpriseWanReplicationService
extends Object
implements com.hazelcast.wan.WanReplicationService, com.hazelcast.spi.FragmentedMigrationAwareService, com.hazelcast.spi.PostJoinAwareService, com.hazelcast.spi.LiveOperationsTracker

Enterprise implementation for WAN replication.

Field Summary

Fields inherited from interface com.hazelcast.wan.WanReplicationService

SERVICE_NAME

Constructor Summary

Constructors

Constructor and Description
EnterpriseWanReplicationService(com.hazelcast.instance.Node node)

Method Summary

Modifier and Type	Method and Description
void	addWanReplicationConfig(com.hazelcast.config.WanReplicationConfig wanConfig)
boolean	addWanReplicationConfigIfAbsent(com.hazelcast.config.WanReplicationConfig wanConfig)
void	beforeMigration(com.hazelcast.spi.PartitionMigrationEvent event)
void	checkWanReplicationQueues(String name)
void	clearQueues(String wanReplicationName, String targetGroupName)
void	commitMigration(com.hazelcast.spi.PartitionMigrationEvent event)
Collection<com.hazelcast.spi.ServiceNamespace>	getAllServiceNamespaces(com.hazelcast.spi.PartitionReplicationEvent event)
WanReplicationEndpoint	getEndpoint(String wanReplicationName, String groupName) Returns a WAN replication configured under a WAN replication config with the name wanReplicationName and with a group name of target.
com.hazelcast.spi.Operation	getPostJoinOperation()
com.hazelcast.wan.impl.WanEventCounter	getReceivedEventCounter(String serviceName)
com.hazelcast.wan.impl.WanEventCounter	getSentEventCounter(String serviceName)
Map<String,com.hazelcast.monitor.LocalWanStats>	getStats() Returns map from WAN replication config name to LocalWanStats.
WanSyncManager	getSyncManager()
com.hazelcast.wan.WanReplicationPublisher	getWanReplicationPublisher(String name)
com.hazelcast.monitor.WanSyncState	getWanSyncState()
void	handleEvent(com.hazelcast.nio.serialization.Data data, WanOperation wanOperation) Processes the replication event sent from the source cluster.
void	handleEvent(com.hazelcast.wan.WanReplicationEvent event)
void	initializeCustomConsumers() Construct and initialize all WAN consumers by fetching the class names or implementations from the config and store them under the WAN replication config name in wanConsumers.
boolean	isKnownServiceNamespace(com.hazelcast.spi.ServiceNamespace namespace)
void	pause(String name, String targetGroupName)
void	populate(com.hazelcast.spi.LiveOperations liveOperations)
void	populateSyncEventOnMembers(String wanReplicationName, String targetGroupName, WanSyncEvent syncEvent)
com.hazelcast.spi.Operation	prepareReplicationOperation(com.hazelcast.spi.PartitionReplicationEvent event)
com.hazelcast.spi.Operation	prepareReplicationOperation(com.hazelcast.spi.PartitionReplicationEvent event, Collection<com.hazelcast.spi.ServiceNamespace> namespaces)
void	publishSyncEvent(String wanReplicationName, String targetGroupName, WanSyncEvent syncEvent)
void	removeWanEventCounters(String serviceName, String dataStructureName)
void	resume(String name, String targetGroupName)
void	rollbackMigration(com.hazelcast.spi.PartitionMigrationEvent event)
void	shutdown()
void	syncAllMaps(String wanReplicationName, String targetGroupName)
void	syncMap(String wanReplicationName, String targetGroupName, String mapName)

Methods inherited from class java.lang.Object

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

Constructor Detail

EnterpriseWanReplicationService

public EnterpriseWanReplicationService(com.hazelcast.instance.Node node)

Method Detail

initializeCustomConsumers

public void initializeCustomConsumers()

Construct and initialize all WAN consumers by fetching the class names or implementations from the config and store them under the WAN replication config name in wanConsumers.

beforeMigration

public void beforeMigration(com.hazelcast.spi.PartitionMigrationEvent event)

Specified by:

beforeMigration in interface com.hazelcast.spi.MigrationAwareService

commitMigration

public void commitMigration(com.hazelcast.spi.PartitionMigrationEvent event)

Specified by:

commitMigration in interface com.hazelcast.spi.MigrationAwareService

rollbackMigration

public void rollbackMigration(com.hazelcast.spi.PartitionMigrationEvent event)

Specified by:

rollbackMigration in interface com.hazelcast.spi.MigrationAwareService

getWanReplicationPublisher

public com.hazelcast.wan.WanReplicationPublisher getWanReplicationPublisher(String name)

Specified by:

getWanReplicationPublisher in interface com.hazelcast.wan.WanReplicationService

getEndpoint

public WanReplicationEndpoint getEndpoint(String wanReplicationName,
                                          String groupName)

Returns a WAN replication configured under a WAN replication config with the name wanReplicationName and with a group name of target.

Parameters:

wanReplicationName - the name of the WanReplicationConfig

groupName - the group name of the publisher

Returns:

the WAN endpoint

Throws:

com.hazelcast.config.InvalidConfigurationException - if there is no replication config with the name wanReplicationName and group name groupName

See Also:

WanReplicationConfig.getName(), WanPublisherConfig.getGroupName()

handleEvent

public void handleEvent(com.hazelcast.nio.serialization.Data data,
                        WanOperation wanOperation)

Processes the replication event sent from the source cluster.

Parameters:

data - the serialized event, can be of type WanReplicationEvent or BatchWanReplicationEvent

wanOperation - the operation sent by the source cluster

handleEvent

public void handleEvent(com.hazelcast.wan.WanReplicationEvent event)

getStats

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

Returns map from WAN replication config name to LocalWanStats.

Specified by:

getStats in interface com.hazelcast.spi.StatisticsAwareService<com.hazelcast.monitor.LocalWanStats>

getWanSyncState

public com.hazelcast.monitor.WanSyncState getWanSyncState()

Specified by:

getWanSyncState in interface com.hazelcast.wan.WanReplicationService

getReceivedEventCounter

public com.hazelcast.wan.impl.WanEventCounter getReceivedEventCounter(String serviceName)

Specified by:

getReceivedEventCounter in interface com.hazelcast.wan.WanReplicationService

getSentEventCounter

public com.hazelcast.wan.impl.WanEventCounter getSentEventCounter(String serviceName)

Specified by:

getSentEventCounter in interface com.hazelcast.wan.WanReplicationService

removeWanEventCounters

public void removeWanEventCounters(String serviceName,
                                   String dataStructureName)

Specified by:

removeWanEventCounters in interface com.hazelcast.wan.WanReplicationService

getPostJoinOperation

public com.hazelcast.spi.Operation getPostJoinOperation()

Specified by:

getPostJoinOperation in interface com.hazelcast.spi.PostJoinAwareService

populate

public void populate(com.hazelcast.spi.LiveOperations liveOperations)

Specified by:

populate in interface com.hazelcast.spi.LiveOperationsTracker

getAllServiceNamespaces

public Collection<com.hazelcast.spi.ServiceNamespace> getAllServiceNamespaces(com.hazelcast.spi.PartitionReplicationEvent event)

Specified by:

getAllServiceNamespaces in interface com.hazelcast.spi.FragmentedMigrationAwareService

isKnownServiceNamespace

public boolean isKnownServiceNamespace(com.hazelcast.spi.ServiceNamespace namespace)

Specified by:

isKnownServiceNamespace in interface com.hazelcast.spi.FragmentedMigrationAwareService

prepareReplicationOperation

public com.hazelcast.spi.Operation prepareReplicationOperation(com.hazelcast.spi.PartitionReplicationEvent event,
                                                               Collection<com.hazelcast.spi.ServiceNamespace> namespaces)

Specified by:

prepareReplicationOperation in interface com.hazelcast.spi.FragmentedMigrationAwareService

prepareReplicationOperation

public com.hazelcast.spi.Operation prepareReplicationOperation(com.hazelcast.spi.PartitionReplicationEvent event)

Specified by:

prepareReplicationOperation in interface com.hazelcast.spi.MigrationAwareService

shutdown

public void shutdown()

Specified by:

shutdown in interface com.hazelcast.wan.WanReplicationService

pause

public void pause(String name,
                  String targetGroupName)

Specified by:

pause in interface com.hazelcast.wan.WanReplicationService

resume

public void resume(String name,
                   String targetGroupName)

Specified by:

resume in interface com.hazelcast.wan.WanReplicationService

checkWanReplicationQueues

public void checkWanReplicationQueues(String name)

Specified by:

checkWanReplicationQueues in interface com.hazelcast.wan.WanReplicationService

syncMap

public void syncMap(String wanReplicationName,
                    String targetGroupName,
                    String mapName)

Specified by:

syncMap in interface com.hazelcast.wan.WanReplicationService

syncAllMaps

public void syncAllMaps(String wanReplicationName,
                        String targetGroupName)

Specified by:

syncAllMaps in interface com.hazelcast.wan.WanReplicationService

clearQueues

public void clearQueues(String wanReplicationName,
                        String targetGroupName)

Specified by:

clearQueues in interface com.hazelcast.wan.WanReplicationService

addWanReplicationConfig

public void addWanReplicationConfig(com.hazelcast.config.WanReplicationConfig wanConfig)

Specified by:

addWanReplicationConfig in interface com.hazelcast.wan.WanReplicationService

addWanReplicationConfigIfAbsent

public boolean addWanReplicationConfigIfAbsent(com.hazelcast.config.WanReplicationConfig wanConfig)

publishSyncEvent

public void publishSyncEvent(String wanReplicationName,
                             String targetGroupName,
                             WanSyncEvent syncEvent)

populateSyncEventOnMembers

public void populateSyncEventOnMembers(String wanReplicationName,
                                       String targetGroupName,
                                       WanSyncEvent syncEvent)

getSyncManager

public WanSyncManager getSyncManager()