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.WanReplicationService

SERVICE_NAME

Constructor Summary

Constructors

Constructor and Description
WanReplicationServiceImpl(Node node)

Method Summary

Modifier and Type	Method and Description
void	addWanReplicationConfig(WanReplicationConfig wanConfig) Adds a new WanReplicationConfig to this member and creates the WanReplicationPublishers specified in the config.
void	checkWanReplicationQueues(String name)
void	clearQueues(String wanReplicationName, String targetGroupName) Clears WAN replication queues of the given wanReplicationName for the given target.
WanEventCounter	getReceivedEventCounter(String serviceName) Returns a counter of received and processed WAN replication events.
WanEventCounter	getSentEventCounter(String serviceName) Returns a counter of sent and processed WAN replication events.
Map<String,LocalWanStats>	getStats() Return the service statistics for the local instance.
WanReplicationPublisher	getWanReplicationPublisher(String name) Creates a new WanReplicationPublisher by the given name.
WanSyncState	getWanSyncState() Returns current status of WAN sync operation
void	pause(String name, String targetGroupName) Pauses wan replication to target group for the called node
void	removeWanEventCounters(String serviceName, String dataStructureName) Removes the WAN event counters for the given dataStructureName.
void	resume(String name, String targetGroupName) Resumes wan replication to target group for the called node.
void	shutdown() Starts the shutdown process of the WAN replication service.
void	syncAllMaps(String wanReplicationName, String targetGroupName) Initiate wan sync for all maps.
void	syncMap(String wanReplicationName, String targetGroupName, 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

getWanReplicationPublisher

public WanReplicationPublisher getWanReplicationPublisher(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:

getWanReplicationPublisher in interface WanReplicationService

Parameters:

name - name of the WAN replication configuration

Returns:

instance of the corresponding replication publisher

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 name,
                  String targetGroupName)

Description copied from interface: WanReplicationService

Pauses wan replication to target group for the called node

Specified by:

pause in interface WanReplicationService

Parameters:

name - name of WAN replication configuration

targetGroupName - name of wan target cluster config

resume

public void resume(String name,
                   String targetGroupName)

Description copied from interface: WanReplicationService

Resumes wan replication to target group for the called node.

Specified by:

resume in interface WanReplicationService

Parameters:

name - name of WAN replication configuration

targetGroupName - name of wan target cluster config

checkWanReplicationQueues

public void checkWanReplicationQueues(String name)

Specified by:

checkWanReplicationQueues in interface WanReplicationService

syncMap

public void syncMap(String wanReplicationName,
                    String targetGroupName,
                    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

targetGroupName - the group name on the target cluster

mapName - the map name

syncAllMaps

public void syncAllMaps(String wanReplicationName,
                        String targetGroupName)

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

targetGroupName - the group name on the target cluster

clearQueues

public void clearQueues(String wanReplicationName,
                        String targetGroupName)

Description copied from interface: WanReplicationService

Clears WAN replication queues of the given wanReplicationName for the given target.

Specified by:

clearQueues in interface WanReplicationService

Parameters:

wanReplicationName - the name of the wan replication config

targetGroupName - the target cluster group name

addWanReplicationConfig

public void addWanReplicationConfig(WanReplicationConfig wanConfig)

Description copied from interface: WanReplicationService

Adds a new WanReplicationConfig to this member and creates the WanReplicationPublishers specified in the config.

Specified by:

addWanReplicationConfig 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

Specified by:

getWanSyncState in interface WanReplicationService

getReceivedEventCounter

public WanEventCounter getReceivedEventCounter(String serviceName)

Description copied from interface: WanReplicationService

Returns a counter of received and processed WAN replication events.

Specified by:

getReceivedEventCounter in interface WanReplicationService

getSentEventCounter

public WanEventCounter getSentEventCounter(String serviceName)

Description copied from interface: WanReplicationService

Returns a counter of sent and processed WAN replication events.

Specified by:

getSentEventCounter in interface WanReplicationService

removeWanEventCounters

public void removeWanEventCounters(String serviceName,
                                   String dataStructureName)

Description copied from interface: WanReplicationService

Removes the WAN event counters for the given dataStructureName.

Specified by:

removeWanEventCounters in interface WanReplicationService