com.hazelcast.wan.impl
Class WanNoDelayReplication

java.lang.Object
  extended by 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
WanNoDelayReplication()
           
 
Method Summary
 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 run()
           
 void shutdown()
          Closes the endpoint, it's 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's password
targets - possible target endpoints bundled in this endpoint

publishReplicationEvent

public void publishReplicationEvent(String serviceName,
                                    ReplicationEventObject eventObject)
Specified by:
publishReplicationEvent in interface WanReplicationPublisher

shutdown

public void shutdown()
Description copied from interface: WanReplicationEndpoint
Closes the endpoint, it's 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)


Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.