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

Modifier and Type	Method	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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PacemakerClient

public PacemakerClient(Map<String,Object> config,
 String host)

Method Details

channelReady

public void channelReady(org.apache.storm.shade.io.netty.channel.Channel channel)

Specified by:

channelReady in interface ISaslClient

name

public String name()

Specified by:

name in interface ISaslClient

secretKey

public String secretKey()

Specified by:

secretKey in interface ISaslClient

send

public HBMessage send(HBMessage m)
               throws PacemakerConnectionException,
InterruptedException

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()