Package org.apache.storm.pacemaker
Class PacemakerClient
- java.lang.Object
-
- org.apache.storm.pacemaker.PacemakerClient
-
- All Implemented Interfaces:
ISaslClient
public class PacemakerClient extends Object implements ISaslClient
-
-
Constructor Summary
Constructors Constructor Description PacemakerClient(Map<String,Object> config, String host)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidchannelReady(org.apache.storm.shade.io.netty.channel.Channel channel)voidclose()voiddoReconnect()voidgotMessage(HBMessage m)Stringname()voidreconnect()StringsecretKey()HBMessagesend(HBMessage m)voidshutdown()
-
-
-
Method Detail
-
channelReady
public void channelReady(org.apache.storm.shade.io.netty.channel.Channel channel)
- Specified by:
channelReadyin interfaceISaslClient
-
name
public String name()
- Specified by:
namein interfaceISaslClient
-
secretKey
public String secretKey()
- Specified by:
secretKeyin interfaceISaslClient
-
send
public HBMessage send(HBMessage m) throws PacemakerConnectionException, InterruptedException
-
gotMessage
public void gotMessage(HBMessage m)
-
reconnect
public void reconnect()
-
doReconnect
public void doReconnect()
-
shutdown
public void shutdown()
-
close
public void close()
-
-