com.hazelcast.wan

Interface WanReplicationService

All Superinterfaces:

CoreService, PacketHandler, StatisticsAwareService

All Known Implementing Classes:

WanReplicationServiceImpl

public interface WanReplicationService
extends CoreService, PacketHandler, StatisticsAwareService

This is the WAN replications service API core interface. The WanReplicationService needs to be capable of creating the actual WanReplicationPublisher instances to replicate values to other clusters over the wide area network, so it has to deal with long delays, slow uploads and higher latencies.

Field Summary

Fields

Modifier and Type	Field and Description
static String	SERVICE_NAME Service name.

Method Summary

Methods

Modifier and Type	Method and Description
void	checkWanReplicationQueues(String name)
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 interface com.hazelcast.spi.StatisticsAwareService

getStats

Field Detail

SERVICE_NAME

static final String SERVICE_NAME

Service name.

See Also:

Constant Field Values

Method Detail

getWanReplicationPublisher

WanReplicationPublisher getWanReplicationPublisher(String name)

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

Parameters:

name - name of the WAN replication configuration

Returns:

instance of the corresponding replication publisher

handle

void handle(Packet packet)

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

Parameters:

packet - the WAN replication packet to process

shutdown

void shutdown()

Starts the shutdown process of the WAN replication service.

pause

void pause(String name,
         String targetGroupName)

Pauses wan replication to target group for the called node

Parameters:

name - name of WAN replication configuration

targetGroupName - name of wan target cluster config

resume

void resume(String name,
          String targetGroupName)

Resumes wan replication to target group for the called node.

Parameters:

name - name of WAN replication configuration

targetGroupName - name of wan target cluster config

checkWanReplicationQueues

void checkWanReplicationQueues(String name)