Package org.apache.storm.pacemaker
Class PacemakerClient
java.lang.Object
org.apache.storm.pacemaker.PacemakerClient
- All Implemented Interfaces:
ISaslClient
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
channelReady
(org.apache.storm.shade.io.netty.channel.Channel channel) void
close()
void
void
name()
void
void
shutdown()
-
Constructor Details
-
PacemakerClient
-
-
Method Details
-
channelReady
public void channelReady(org.apache.storm.shade.io.netty.channel.Channel channel) - Specified by:
channelReady
in interfaceISaslClient
-
name
- Specified by:
name
in interfaceISaslClient
-
secretKey
- Specified by:
secretKey
in interfaceISaslClient
-
send
-
gotMessage
-
reconnect
public void reconnect() -
doReconnect
public void doReconnect() -
shutdown
public void shutdown() -
close
public void close()
-