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.ManagedService, 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, com.hazelcast.spi.ManagedService

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
com.hazelcast.wan.AddWanConfigResult	addWanReplicationConfig(com.hazelcast.config.WanReplicationConfig wanConfig)
void	addWanReplicationConfigLocally(com.hazelcast.config.WanReplicationConfig wanConfig)
void	appendWanReplicationConfig(com.hazelcast.config.WanReplicationConfig newConfig) Appends the provided WanReplicationConfig to the configuration of this member.
void	beforeMigration(com.hazelcast.spi.PartitionMigrationEvent event)
void	checkWanReplicationQueues(String name)
void	clearQueues(String wanReplicationName, String wanPublisherId)
void	commitMigration(com.hazelcast.spi.PartitionMigrationEvent event)
void	consistencyCheck(String wanReplicationName, String wanPublisherId, String mapName)
Collection<com.hazelcast.spi.ServiceNamespace>	getAllServiceNamespaces(com.hazelcast.spi.PartitionReplicationEvent event)
WanReplicationEndpoint	getEndpointOrFail(String wanReplicationName, String wanPublisherId) Returns a WAN replication configured under a WAN replication config with the name wanReplicationName and with a WAN publisher ID of wanPublisherId or throws a InvalidConfigurationException if there is no configuration for the given parameters.
WanReplicationEndpoint	getEndpointOrNull(String wanReplicationName, String wanPublisherId) Returns a WAN replication configured under a WAN replication config with the name wanReplicationName and with a WAN publisher ID of wanPublisherId or null if there is no configuration for the given parameters.
com.hazelcast.spi.Operation	getPostJoinOperation()
static String	getPublisherIdOrGroupName(com.hazelcast.config.WanPublisherConfig publisherConfig) Returns the publisher ID for the given WAN publisher configuration which is then used for identifying the WAN publisher in a WAN replication scheme.
com.hazelcast.wan.impl.DistributedServiceWanEventCounters	getReceivedEventCounters(String serviceName)
com.hazelcast.wan.impl.DistributedServiceWanEventCounters	getSentEventCounters(String wanReplicationName, String wanPublisherId, String serviceName)
Map<String,com.hazelcast.monitor.LocalWanStats>	getStats() Returns map from WAN replication config name to LocalWanStats.
WanSyncManager	getSyncManager() Returns the manager for WAN sync events.
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	init(com.hazelcast.spi.NodeEngine nodeEngine, Properties properties)
void	initializeCustomConsumers() Constructs and initializes all WAN consumers defined in the WAN configuration
boolean	isKnownServiceNamespace(com.hazelcast.spi.ServiceNamespace namespace)
void	pause(String wanReplicationName, String wanPublisherId)
void	populate(com.hazelcast.spi.LiveOperations liveOperations)
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	publishAntiEntropyEvent(String wanReplicationName, String wanPublisherId, WanAntiEntropyEvent event) Publishes an anti-entropy event for the given wanReplicationName and wanPublisherId.
void	removeWanEventCounters(String serviceName, String dataStructureName)
void	reset()
void	resume(String wanReplicationName, String wanPublisherId)
void	rollbackMigration(com.hazelcast.spi.PartitionMigrationEvent event)
void	shutdown()
void	shutdown(boolean terminate)
void	stop(String wanReplicationName, String wanPublisherId)
void	syncAllMaps(String wanReplicationName, String wanPublisherId)
void	syncMap(String wanReplicationName, String wanPublisherId, 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

getEndpointOrNull

public WanReplicationEndpoint getEndpointOrNull(String wanReplicationName,
                                                String wanPublisherId)

Returns a WAN replication configured under a WAN replication config with the name wanReplicationName and with a WAN publisher ID of wanPublisherId or null if there is no configuration for the given parameters.

Parameters:

wanReplicationName - the name of the WanReplicationConfig

wanPublisherId - the publisher ID

Returns:

the WAN endpoint or null if there is no configuration for the given parameters

See Also:

WanReplicationConfig.getName(), WanPublisherConfig.getGroupName(), WanPublisherConfig.getPublisherId()

getEndpointOrFail

public WanReplicationEndpoint getEndpointOrFail(String wanReplicationName,
                                                String wanPublisherId)

Returns a WAN replication configured under a WAN replication config with the name wanReplicationName and with a WAN publisher ID of wanPublisherId or throws a InvalidConfigurationException if there is no configuration for the given parameters.

Parameters:

wanReplicationName - the name of the WanReplicationConfig

wanPublisherId - the publisher ID

Returns:

the WAN endpoint

Throws:

com.hazelcast.config.InvalidConfigurationException - if there is no replication config with the name wanReplicationName and publisher ID wanPublisherId

See Also:

WanReplicationConfig.getName(), WanPublisherConfig.getGroupName(), WanPublisherConfig.getPublisherId()

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

appendWanReplicationConfig

public void appendWanReplicationConfig(com.hazelcast.config.WanReplicationConfig newConfig)

Appends the provided WanReplicationConfig to the configuration of this member. If there is no WAN replication config with the same name/scheme, the provided config will be used. If there is an existing WAN replication config with the same name, any publishers with publisher IDs that are present in the provided newConfig but not present in the existing config will be added (appended). If the existing config contains all of the publishers from the provided config, no change is done to the existing config. This method is thread-safe and may be called concurrently.

Parameters:

newConfig - the WAN configuration to add

See Also:

WanPublisherConfig.getPublisherId()

publishAntiEntropyEvent

public void publishAntiEntropyEvent(String wanReplicationName,
                                    String wanPublisherId,
                                    WanAntiEntropyEvent event)

Publishes an anti-entropy event for the given wanReplicationName and wanPublisherId. This method does not wait for the event processing to complete.

Parameters:

wanReplicationName - the WAN replication config name

wanPublisherId - the publisher ID in the WAN replication config

event - the WAN anti-entropy event

Throws:

com.hazelcast.config.InvalidConfigurationException - if there is no replication config with the wanReplicationName and wanPublisherId

getSyncManager

public WanSyncManager getSyncManager()

Returns the manager for WAN sync events.

initializeCustomConsumers

public void initializeCustomConsumers()

Constructs and initializes all WAN consumers defined in the WAN configuration

See Also:

WanReplicationConsumer

handleEvent

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

getWanReplicationPublisher

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

Specified by:

getWanReplicationPublisher in interface com.hazelcast.wan.WanReplicationService

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>

getPublisherIdOrGroupName

public static String getPublisherIdOrGroupName(com.hazelcast.config.WanPublisherConfig publisherConfig)

Returns the publisher ID for the given WAN publisher configuration which is then used for identifying the WAN publisher in a WAN replication scheme. If the publisher ID is empty, returns the publisher group name.

Parameters:

publisherConfig - the WAN replication publisher configuration

Returns:

the publisher ID or group name

getWanSyncState

public com.hazelcast.monitor.WanSyncState getWanSyncState()

Specified by:

getWanSyncState in interface com.hazelcast.wan.WanReplicationService

getReceivedEventCounters

public com.hazelcast.wan.impl.DistributedServiceWanEventCounters getReceivedEventCounters(String serviceName)

Specified by:

getReceivedEventCounters in interface com.hazelcast.wan.WanReplicationService

getSentEventCounters

public com.hazelcast.wan.impl.DistributedServiceWanEventCounters getSentEventCounters(String wanReplicationName,
                                                                                      String wanPublisherId,
                                                                                      String serviceName)

Specified by:

getSentEventCounters 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

shutdown

public void shutdown()

Specified by:

shutdown in interface com.hazelcast.wan.WanReplicationService

pause

public void pause(String wanReplicationName,
                  String wanPublisherId)

Specified by:

pause in interface com.hazelcast.wan.WanReplicationService

stop

public void stop(String wanReplicationName,
                 String wanPublisherId)

Specified by:

stop in interface com.hazelcast.wan.WanReplicationService

resume

public void resume(String wanReplicationName,
                   String wanPublisherId)

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 wanPublisherId,
                    String mapName)

Specified by:

syncMap in interface com.hazelcast.wan.WanReplicationService

syncAllMaps

public void syncAllMaps(String wanReplicationName,
                        String wanPublisherId)

Specified by:

syncAllMaps in interface com.hazelcast.wan.WanReplicationService

consistencyCheck

public void consistencyCheck(String wanReplicationName,
                             String wanPublisherId,
                             String mapName)

Specified by:

consistencyCheck in interface com.hazelcast.wan.WanReplicationService

clearQueues

public void clearQueues(String wanReplicationName,
                        String wanPublisherId)

Specified by:

clearQueues in interface com.hazelcast.wan.WanReplicationService

addWanReplicationConfigLocally

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

Specified by:

addWanReplicationConfigLocally in interface com.hazelcast.wan.WanReplicationService

addWanReplicationConfig

public com.hazelcast.wan.AddWanConfigResult addWanReplicationConfig(com.hazelcast.config.WanReplicationConfig wanConfig)

Specified by:

addWanReplicationConfig in interface com.hazelcast.wan.WanReplicationService

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

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

init

public void init(com.hazelcast.spi.NodeEngine nodeEngine,
                 Properties properties)

Specified by:

init in interface com.hazelcast.spi.ManagedService

reset

public void reset()

Specified by:

reset in interface com.hazelcast.spi.ManagedService

shutdown

public void shutdown(boolean terminate)

Specified by:

shutdown in interface com.hazelcast.spi.ManagedService