org.apache.flume.node.nodemanager
Class DefaultLogicalNodeManager

java.lang.Object
  org.apache.flume.node.nodemanager.AbstractLogicalNodeManager
      org.apache.flume.node.nodemanager.DefaultLogicalNodeManager

All Implemented Interfaces:

LifecycleAware, NodeManager, NodeConfigurationAware

public class DefaultLogicalNodeManager
extends AbstractLogicalNodeManager
implements NodeConfigurationAware

Field Summary

static String	CONF_MONITOR_CLASS
static String	CONF_MONITOR_PREFIX

Constructor Summary

DefaultLogicalNodeManager()

Method Summary

boolean	add(LifecycleAware node)
LifecycleState	getLifecycleState() Return the current state of the service or component.
boolean	remove(LifecycleAware node)
void	start() Starts a service or component.
void	startAllComponents(NodeConfiguration nodeConfiguration) Start components with the configuration provided.
void	stop() Stops a service or component.
void	stopAllComponents() Stop all components currently running.

Methods inherited from class org.apache.flume.node.nodemanager.AbstractLogicalNodeManager

getNodes, setNodes, toString

Methods inherited from class java.lang.Object

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

Field Detail

CONF_MONITOR_CLASS

public static final String CONF_MONITOR_CLASS

See Also:

Constant Field Values

CONF_MONITOR_PREFIX

public static final String CONF_MONITOR_PREFIX

See Also:

Constant Field Values

Constructor Detail

DefaultLogicalNodeManager

public DefaultLogicalNodeManager()

Method Detail

stopAllComponents

public void stopAllComponents()

Description copied from interface: NodeConfigurationAware

Stop all components currently running.

Specified by:

stopAllComponents in interface NodeConfigurationAware

startAllComponents

public void startAllComponents(NodeConfiguration nodeConfiguration)

Description copied from interface: NodeConfigurationAware

Start components with the configuration provided.

Specified by:

startAllComponents in interface NodeConfigurationAware

add

public boolean add(LifecycleAware node)

Specified by:

add in interface NodeManager

Overrides:

add in class AbstractLogicalNodeManager

remove

public boolean remove(LifecycleAware node)

Specified by:

remove in interface NodeManager

Overrides:

remove in class AbstractLogicalNodeManager

start

public void start()

Description copied from interface: LifecycleAware

Starts a service or component.

Implementations should determine the result of any start logic and effect the return value of LifecycleAware.getLifecycleState() accordingly.

Specified by:

start in interface LifecycleAware

stop

public void stop()

Description copied from interface: LifecycleAware

Stops a service or component.

Implementations should determine the result of any stop logic and effect the return value of LifecycleAware.getLifecycleState() accordingly.

Specified by:

stop in interface LifecycleAware

getLifecycleState

public LifecycleState getLifecycleState()

Description copied from interface: LifecycleAware

Return the current state of the service or component.

Specified by:

getLifecycleState in interface LifecycleAware