public class PacemakerClient extends Object implements ISaslClient
| Constructor and Description |
|---|
PacemakerClient(Map<String,Object> config,
String host) |
| Modifier and Type | Method and Description |
|---|---|
void |
channelReady(org.apache.storm.shade.io.netty.channel.Channel channel) |
void |
close() |
void |
doReconnect() |
void |
gotMessage(HBMessage m) |
String |
name() |
void |
reconnect() |
String |
secretKey() |
HBMessage |
send(HBMessage m) |
void |
shutdown() |
public void channelReady(org.apache.storm.shade.io.netty.channel.Channel channel)
channelReady in interface ISaslClientpublic String name()
name in interface ISaslClientpublic String secretKey()
secretKey in interface ISaslClientpublic HBMessage send(HBMessage m) throws PacemakerConnectionException, InterruptedException
public void gotMessage(HBMessage m)
public void reconnect()
public void doReconnect()
public void shutdown()
public void close()
Copyright © 2021 The Apache Software Foundation. All rights reserved.