com.hazelcast.wan.impl

Class WanReplicationServiceImpl

java.lang.Object

com.hazelcast.wan.impl.WanReplicationServiceImpl

All Implemented Interfaces:

CoreService, StatisticsAwareService<LocalWanStats>, WanReplicationService

public class WanReplicationServiceImpl
extends Object
implements WanReplicationService

Open source implementation of the WanReplicationService

Field Summary

Fields inherited from interface com.hazelcast.wan.impl.WanReplicationService

SERVICE_NAME

Constructor Summary

Constructors

Constructor and Description
WanReplicationServiceImpl(Node node)

Method Summary

Modifier and Type	Method and Description
AddWanConfigResult	addWanReplicationConfig(WanReplicationConfig wanConfig) Adds a new WanReplicationConfig to the cluster.
void	addWanReplicationConfigLocally(WanReplicationConfig wanConfig) Adds a new WanReplicationConfig to this member and creates the WanReplicationPublishers specified in the config.
UUID	consistencyCheck(String wanReplicationName, String wanPublisherId, String mapName) Initiate WAN consistency check for a specific map.
DistributedServiceWanEventCounters	getReceivedEventCounters(String serviceName) Returns a counter of received and processed WAN replication events.
DistributedServiceWanEventCounters	getSentEventCounters(String wanReplicationName, String wanPublisherId, String serviceName) Returns a counter of sent and processed WAN replication events.
Map<String,LocalWanStats>	getStats() Return the service statistics for the local instance.
List<Version>	getSupportedWanProtocolVersions() Returns an immutable collection of all WAN protocol versions supported by this instance.
static String	getWanPublisherId(AbstractWanPublisherConfig 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.
DelegatingWanReplicationScheme	getWanReplicationPublishers(String name) Creates a new WanReplicationPublisher by the given name.
WanSyncState	getWanSyncState() Returns current status of WAN sync operation or null when there is no status.
void	pause(String wanReplicationName, String wanPublisherId) Pauses WAN replication for the given wanReplicationName and wanPublisherId on this hazelcast instance.
void	removeWanEventCounters(String serviceName, String objectName) Removes all WAN event counters for the given serviceName and dataStructureName.
void	removeWanEvents(String wanReplicationName, String wanPublisherId) Removes all WAN events awaiting replication for the given wanReplicationName for the given target.
void	resume(String wanReplicationName, String wanPublisherId) Resumes WAN replication for the given wanReplicationName and wanPublisherId on this hazelcast instance.
void	shutdown() Starts the shutdown process of the WAN replication service.
void	stop(String wanReplicationName, String wanPublisherId) Stops WAN replication for the given wanReplicationName and wanPublisherId on this hazelcast instance.
UUID	syncAllMaps(String wanReplicationName, String wanPublisherId) Initiate wan sync for all maps.
UUID	syncMap(String wanReplicationName, String wanPublisherId, String mapName) Initiate wan sync for a specific map.

Methods inherited from class java.lang.Object

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

Constructor Detail

WanReplicationServiceImpl

public WanReplicationServiceImpl(Node node)

Method Detail

getWanReplicationPublishers

public DelegatingWanReplicationScheme getWanReplicationPublishers(String name)

Description copied from interface: WanReplicationService

Creates a new WanReplicationPublisher by the given name. If the name already exists, returns the previous instance.

Specified by:

getWanReplicationPublishers in interface WanReplicationService

Parameters:

name - name of the WAN replication configuration

Returns:

instance of the corresponding replication publisher

getWanPublisherId

@Nonnull
public static String getWanPublisherId(AbstractWanPublisherConfig 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 WAN publisher ID

shutdown

public void shutdown()

Description copied from interface: WanReplicationService

Starts the shutdown process of the WAN replication service.

Specified by:

shutdown in interface WanReplicationService

pause

public void pause(String wanReplicationName,
                  String wanPublisherId)

Description copied from interface: WanReplicationService

Pauses WAN replication for the given wanReplicationName and wanPublisherId on this hazelcast instance.

Specified by:

pause in interface WanReplicationService

Parameters:

wanReplicationName - name of WAN replication configuration

wanPublisherId - ID of the WAN replication publisher

stop

public void stop(String wanReplicationName,
                 String wanPublisherId)

Description copied from interface: WanReplicationService

Stops WAN replication for the given wanReplicationName and wanPublisherId on this hazelcast instance.

Specified by:

stop in interface WanReplicationService

Parameters:

wanReplicationName - name of WAN replication configuration

wanPublisherId - ID of the WAN replication publisher

resume

public void resume(String wanReplicationName,
                   String wanPublisherId)

Description copied from interface: WanReplicationService

Resumes WAN replication for the given wanReplicationName and wanPublisherId on this hazelcast instance.

Specified by:

resume in interface WanReplicationService

Parameters:

wanReplicationName - name of WAN replication configuration

wanPublisherId - ID of the WAN replication publisher

syncMap

public UUID syncMap(String wanReplicationName,
                    String wanPublisherId,
                    String mapName)

Description copied from interface: WanReplicationService

Initiate wan sync for a specific map. NOTE: not supported on OS, only on EE

Specified by:

syncMap in interface WanReplicationService

Parameters:

wanReplicationName - the name of the wan replication config

wanPublisherId - ID of the WAN replication publisher

mapName - the map name

Returns:

the UUID of the synchronization

syncAllMaps

public UUID syncAllMaps(String wanReplicationName,
                        String wanPublisherId)

Description copied from interface: WanReplicationService

Initiate wan sync for all maps. NOTE: not supported on OS, only on EE

Specified by:

syncAllMaps in interface WanReplicationService

Parameters:

wanReplicationName - the name of the wan replication config

wanPublisherId - ID of the WAN replication publisher

Returns:

the UUID of the synchronization

consistencyCheck

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

Description copied from interface: WanReplicationService

Initiate WAN consistency check for a specific map. NOTE: not supported on OS, only on EE

Specified by:

consistencyCheck in interface WanReplicationService

Parameters:

wanReplicationName - the name of the wan replication config

wanPublisherId - ID of the WAN replication publisher

mapName - the map name

Returns:

the UUID of the consistency check request or null if consistency check is ignored because of the configuration

removeWanEvents

public void removeWanEvents(String wanReplicationName,
                            String wanPublisherId)

Description copied from interface: WanReplicationService

Removes all WAN events awaiting replication for the given wanReplicationName for the given target. If the publisher does not store WAN events, this method is a no-op. Invoked when clearing the WAN replication data, e.g. because of a REST call.

Specified by:

removeWanEvents in interface WanReplicationService

Parameters:

wanReplicationName - the name of the wan replication config

wanPublisherId - ID of the WAN replication publisher

addWanReplicationConfig

public AddWanConfigResult addWanReplicationConfig(WanReplicationConfig wanConfig)

Description copied from interface: WanReplicationService

Adds a new WanReplicationConfig to the cluster. This method can also accept WAN configs with an existing WAN replication name. Such configs will be merged into the existing WAN replication config by adding publishers with publisher IDs which are not already part of the existing configuration. The return value is a best-effort guess at the result of adding WAN replication config based on the existing local WAN replication config. An exact result is difficult to calculate since not all members might have the same existing configuration and there might be a concurrent request to add overlapping WAN replication config.

Specified by:

addWanReplicationConfig in interface WanReplicationService

Parameters:

wanConfig - the WAN replication config to add

Returns:

a best-effort guess at the result of adding WAN replication config

See Also:

WanReplicationService.addWanReplicationConfigLocally(WanReplicationConfig)

addWanReplicationConfigLocally

public void addWanReplicationConfigLocally(WanReplicationConfig wanConfig)

Description copied from interface: WanReplicationService

Adds a new WanReplicationConfig to this member and creates the WanReplicationPublishers specified in the config. This method can also accept WAN configs with an existing WAN replication name. Such configs will be merged into the existing WAN replication config by adding publishers with publisher IDs which are not already part of the existing configuration.

Specified by:

addWanReplicationConfigLocally in interface WanReplicationService

getStats

public Map<String,LocalWanStats> getStats()

Description copied from interface: StatisticsAwareService

Return the service statistics for the local instance.

Specified by:

getStats in interface StatisticsAwareService<LocalWanStats>

Returns:

the statistics, grouped by distributed object name

getWanSyncState

public WanSyncState getWanSyncState()

Description copied from interface: WanReplicationService

Returns current status of WAN sync operation or null when there is no status.

Specified by:

getWanSyncState in interface WanReplicationService

getReceivedEventCounters

public DistributedServiceWanEventCounters getReceivedEventCounters(String serviceName)

Description copied from interface: WanReplicationService

Returns a counter of received and processed WAN replication events.

Specified by:

getReceivedEventCounters in interface WanReplicationService

Parameters:

serviceName - the name of the service for the WAN events

Returns:

the WAN event counter

getSentEventCounters

public DistributedServiceWanEventCounters getSentEventCounters(String wanReplicationName,
                                                               String wanPublisherId,
                                                               String serviceName)

Description copied from interface: WanReplicationService

Returns a counter of sent and processed WAN replication events.

Specified by:

getSentEventCounters in interface WanReplicationService

Parameters:

wanReplicationName - the name of the wan replication config

wanPublisherId - WAN replication publisher ID

serviceName - the name of the service for the WAN events

Returns:

the WAN event counter

removeWanEventCounters

public void removeWanEventCounters(String serviceName,
                                   String objectName)

Description copied from interface: WanReplicationService

Removes all WAN event counters for the given serviceName and dataStructureName.

Specified by:

removeWanEventCounters in interface WanReplicationService

Parameters:

serviceName - the name of the service for the WAN events

objectName - the distributed object name

getSupportedWanProtocolVersions

public List<Version> getSupportedWanProtocolVersions()

Description copied from interface: WanReplicationService

Returns an immutable collection of all WAN protocol versions supported by this instance.

Specified by:

getSupportedWanProtocolVersions in interface WanReplicationService