public class WanNoDelayReplication extends Object implements Runnable, WanReplicationEndpoint
Constructor and Description |
---|
WanNoDelayReplication() |
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
|
public void init(Node node, String groupName, String password, String... targets)
WanReplicationEndpoint
init
in interface WanReplicationEndpoint
node
- the current node that tries to connectgroupName
- the group name to connect withpassword
- the group passwordtargets
- possible target endpoints bundled in this endpointpublic void publishReplicationEvent(String serviceName, ReplicationEventObject eventObject)
publishReplicationEvent
in interface WanReplicationPublisher
public void publishReplicationEventBackup(String serviceName, ReplicationEventObject eventObject)
publishReplicationEventBackup
in interface WanReplicationPublisher
public void publishReplicationEvent(WanReplicationEvent wanReplicationEvent)
publishReplicationEvent
in interface WanReplicationPublisher
public void shutdown()
WanReplicationEndpoint
shutdown
in interface WanReplicationEndpoint
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.