com.hazelcast.wan.impl

Class WanReplicationServiceImpl

java.lang.Object

com.hazelcast.wan.impl.WanReplicationServiceImpl

All Implemented Interfaces:

CoreService, PacketHandler, 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	handle(Packet packet) This method is called when a replication packet arrives at the connection handler.
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.

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

handle

public void handle(Packet packet)

Description copied from interface: WanReplicationService

This method is called when a replication packet arrives at the connection handler. WAN replication messages are handled directly instead of going through the normal message process.

Specified by:

handle in interface PacketHandler

Specified by:

handle in interface WanReplicationService

Parameters:

packet - the WAN replication packet to process

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

getStats

public Map<String,LocalWanStats> getStats()

Specified by:

getStats in interface StatisticsAwareService