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

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

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