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 and Description
PacemakerClient()
PacemakerClient(Map config, String host)

Method Summary

Modifier and Type	Method and Description
void	channelConnected(org.jboss.netty.channel.Channel channel)
void	channelReady()
void	close()
void	doReconnect()
void	gotMessage(HBMessage m)
boolean	isReady()
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 Detail

PacemakerClient

public PacemakerClient()

PacemakerClient

public PacemakerClient(Map config,
                       String host)

Method Detail

isReady

public boolean isReady()

channelConnected

public void channelConnected(org.jboss.netty.channel.Channel channel)

Specified by:

channelConnected in interface ISaslClient

channelReady

public void channelReady()

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

Throws:

PacemakerConnectionException

gotMessage

public void gotMessage(HBMessage m)

reconnect

public void reconnect()

doReconnect

public void doReconnect()

shutdown

public void shutdown()

close

public void close()