com.hazelcast.wan.impl

Class WanReplicationServiceImpl

java.lang.Object

com.hazelcast.wan.impl.WanReplicationServiceImpl

All Implemented Interfaces:

CoreService, StatisticsAwareService, 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

Methods

Modifier and Type	Method and Description
void	checkWanReplicationQueues(String name)
Map<String,LocalWanStats>	getStats()
WanReplicationPublisher	getWanReplicationPublisher(String name) Creates a new WanReplicationPublisher by the given name.
void	pause(String name, String targetGroupName) Pauses wan replication to target group for the called node
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	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

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)

Specified by:

syncMap in interface WanReplicationService

getStats

public Map<String,LocalWanStats> getStats()

Specified by:

getStats in interface StatisticsAwareService