com.hazelcast.wan.impl

Class WanNoDelayReplication

java.lang.Object

com.hazelcast.wan.impl.WanNoDelayReplication

All Implemented Interfaces:

WanReplicationEndpoint, WanReplicationPublisher, Runnable

public class WanNoDelayReplication
extends Object
implements Runnable, WanReplicationEndpoint

No delaying distribution implementation on WAN replication

Constructor Summary

Constructors

Constructor and Description
WanNoDelayReplication()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	checkAuthorization(String groupName, String groupPassword, Address target)
void	init(Node node, String groupName, String password, String... targets) Initializes the endpoint using the given arguments.
void	publishReplicationEvent(String serviceName, ReplicationEventObject eventObject)
void	publishReplicationEvent(WanReplicationEvent wanReplicationEvent)
void	publishReplicationEventBackup(String serviceName, ReplicationEventObject eventObject)
void	run()
void	shutdown() Closes the endpoint and its internal connections and shuts down other internal states

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WanNoDelayReplication

public WanNoDelayReplication()

Method Detail

init

public void init(Node node,
        String groupName,
        String password,
        String... targets)

Description copied from interface: WanReplicationEndpoint

Initializes the endpoint using the given arguments.

Specified by:

init in interface WanReplicationEndpoint

Parameters:

node - the current node that tries to connect

groupName - the group name to connect with

password - the group password

targets - possible target endpoints bundled in this endpoint

publishReplicationEvent

public void publishReplicationEvent(String serviceName,
                           ReplicationEventObject eventObject)

Specified by:

publishReplicationEvent in interface WanReplicationPublisher

publishReplicationEventBackup

public void publishReplicationEventBackup(String serviceName,
                                 ReplicationEventObject eventObject)

Specified by:

publishReplicationEventBackup in interface WanReplicationPublisher

publishReplicationEvent

public void publishReplicationEvent(WanReplicationEvent wanReplicationEvent)

Specified by:

publishReplicationEvent in interface WanReplicationPublisher

shutdown

public void shutdown()

Description copied from interface: WanReplicationEndpoint

Closes the endpoint and its internal connections and shuts down other internal states

Specified by:

shutdown in interface WanReplicationEndpoint

run

public void run()

Specified by:

run in interface Runnable

checkAuthorization

public boolean checkAuthorization(String groupName,
                         String groupPassword,
                         Address target)