com.hazelcast.wan.impl

Class WanReplicationServiceImpl

java.lang.Object

com.hazelcast.wan.impl.WanReplicationServiceImpl

All Implemented Interfaces:

CoreService, 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
WanReplicationPublisher	getWanReplicationPublisher(String name) Creates a new WanReplicationPublisher by the given name.
void	handleEvent(Packet packet) This method is called when a replication packet arrives at the connection handler.
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

handleEvent

public void handleEvent(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:

handleEvent 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