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

WanReplicationServiceImpl(Node node)

Method Summary

WanReplicationPublisher	getWanReplicationPublisher(String name) Creates a new WanReplicationPublisher by the given name, if already existing returns the previous instance.
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 already existing 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