org.apache.ambari.server.agent

Class HeartbeatMonitor

java.lang.Object

org.apache.ambari.server.agent.HeartbeatMonitor

All Implemented Interfaces:

Runnable

public class HeartbeatMonitor
extends Object
implements Runnable

Monitors the node state and heartbeats.

Constructor Summary

Constructors

Constructor and Description
HeartbeatMonitor(Clusters clusters, ActionManager am, int threadWakeupInterval, com.google.inject.Injector injector)

Method Summary

Modifier and Type	Method and Description
List<StatusCommand>	generateStatusCommands(String hostname)
AgentRequests	getAgentRequests()
boolean	isAlive()
void	onMessageNotDelivered(MessageNotDelivered messageNotDelivered)
void	run()
void	shutdown()
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

HeartbeatMonitor

public HeartbeatMonitor(Clusters clusters,
                        ActionManager am,
                        int threadWakeupInterval,
                        com.google.inject.Injector injector)

Method Detail

shutdown

public void shutdown()

start

public void start()

isAlive

public boolean isAlive()

getAgentRequests

public AgentRequests getAgentRequests()

run

public void run()

Specified by:

run in interface Runnable

generateStatusCommands

public List<StatusCommand> generateStatusCommands(String hostname)
                                           throws org.apache.ambari.server.AmbariException

Parameters:

hostname -

Returns:

list of commands to get status of service components on a concrete host

Throws:

org.apache.ambari.server.AmbariException

onMessageNotDelivered

public void onMessageNotDelivered(MessageNotDelivered messageNotDelivered)