org.opennms.netmgt.collectd

Class Collectd

java.lang.Object

org.opennms.netmgt.daemon.AbstractServiceDaemon

org.opennms.netmgt.collectd.Collectd

All Implemented Interfaces:

Fiber, PausableFiber, SpringServiceDaemon, EventListener, ServiceDaemon, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean

public class Collectd
extends AbstractServiceDaemon
implements EventListener

Collectd class.

Version:

$Id: $

Author:

ranger

Field Summary

Fields inherited from interface org.opennms.core.fiber.PausableFiber

PAUSE_PENDING, PAUSED, RESUME_PENDING

Fields inherited from interface org.opennms.core.fiber.Fiber

RUNNING, START_PENDING, STARTING, STATUS_NAMES, STOP_PENDING, STOPPED

Constructor Summary

Constructors

Constructor and Description
Collectd() Constructor.

Method Summary

Modifier and Type	Method and Description
long	getCollectableServiceCount()
protected List<org.opennms.netmgt.collectd.CollectableService>	getCollectableServices()
Set<String>	getCollectorNames() getCollectorNames
EventIpcManager	getEventIpcManager() getEventIpcManager
static String	getLoggingCategory()
PersisterFactory	getPersisterFactory()
Scheduler	getScheduler() getScheduler
ServiceCollector	getServiceCollector(String svcName) getServiceCollector
Collection<CollectionSpecification>	getSpecificationsForInterface(OnmsIpInterface iface, String svcName) getSpecificationsForInterface
ThresholdingService	getThresholdingService()
protected void	handleInsufficientInfo(InsufficientInformationException e) handleInsufficientInfo
static CollectionInstrumentation	instrumentation() instrumentation
void	onEvent(IEvent event) Process a sent event.
protected void	onInit() onInit
protected void	onPause() onPause
protected void	onResume() onResume
protected void	onStart() onStart
protected void	onStop() onStop
void	setEventIpcManager(EventIpcManager eventIpcManager) setEventIpcManager
void	setLocationAwareCollectorClient(LocationAwareCollectorClient locationAwareCollectorClient)
void	setPersisterFactory(PersisterFactory persisterFactory)
void	setPollOutagesDao(ReadablePollOutagesDao pollOutagesDao)
void	setScheduler(Scheduler scheduler) setScheduler
void	setServiceCollector(String svcName, ServiceCollector collector) setServiceCollector
void	setServiceCollectorRegistry(ServiceCollectorRegistry serviceCollectorRegistry)
void	setThresholdingService(ThresholdingService thresholdingService)

Methods inherited from class org.opennms.netmgt.daemon.AbstractServiceDaemon

afterPropertiesSet, destroy, getName, getStatus, getStatusText, init, isPaused, isRunning, isStarting, pause, resume, setStatus, start, status, stop, waitForStatus, waitForStatus

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.opennms.netmgt.events.api.EventListener

getName

Constructor Detail

Collectd

public Collectd()

Constructor.

Method Detail

instrumentation

public static CollectionInstrumentation instrumentation()

instrumentation

Returns:

a CollectionInstrumentation object.

onInit

protected void onInit()

onInit

Specified by:

onInit in class AbstractServiceDaemon

setEventIpcManager

public void setEventIpcManager(EventIpcManager eventIpcManager)

setEventIpcManager

Parameters:

eventIpcManager - a EventIpcManager object.

getEventIpcManager

public EventIpcManager getEventIpcManager()

getEventIpcManager

Returns:

a EventIpcManager object.

getThresholdingService

public ThresholdingService getThresholdingService()

setThresholdingService

public void setThresholdingService(ThresholdingService thresholdingService)

onStart

protected void onStart()

onStart

Overrides:

onStart in class AbstractServiceDaemon

onStop

protected void onStop()

onStop

Overrides:

onStop in class AbstractServiceDaemon

onPause

protected void onPause()

onPause

Overrides:

onPause in class AbstractServiceDaemon

onResume

protected void onResume()

onResume

Overrides:

onResume in class AbstractServiceDaemon

getSpecificationsForInterface

public Collection<CollectionSpecification> getSpecificationsForInterface(OnmsIpInterface iface,
                                                                         String svcName)

getSpecificationsForInterface

Parameters:

iface - a OnmsIpInterface object.

svcName - a String object.

Returns:

a Collection object.

getCollectableServices

protected List<org.opennms.netmgt.collectd.CollectableService> getCollectableServices()

onEvent

public void onEvent(IEvent event)

Process a sent event. This method is invoked by the JMS topic session when a new event is available for processing. Currently only text based messages are processed by this callback. Each message is examined for its Universal Event Identifier and the appropriate action is taking based on each UEI.

Specified by:

onEvent in interface EventListener

Parameters:

event - a IEvent object.

handleInsufficientInfo

protected void handleInsufficientInfo(InsufficientInformationException e)

handleInsufficientInfo

Parameters:

e - a InsufficientInformationException object.

setScheduler

public void setScheduler(Scheduler scheduler)

setScheduler

Parameters:

scheduler - a Scheduler object.

getScheduler

public Scheduler getScheduler()

getScheduler

Returns:

a Scheduler object.

setServiceCollectorRegistry

public void setServiceCollectorRegistry(ServiceCollectorRegistry serviceCollectorRegistry)

setLocationAwareCollectorClient

public void setLocationAwareCollectorClient(LocationAwareCollectorClient locationAwareCollectorClient)

setServiceCollector

public void setServiceCollector(String svcName,
                                ServiceCollector collector)

setServiceCollector

Parameters:

svcName - a String object.

collector - a ServiceCollector object.

getServiceCollector

public ServiceCollector getServiceCollector(String svcName)

getServiceCollector

Parameters:

svcName - a String object.

Returns:

a ServiceCollector object.

getPersisterFactory

public PersisterFactory getPersisterFactory()

setPersisterFactory

public void setPersisterFactory(PersisterFactory persisterFactory)

getCollectorNames

public Set<String> getCollectorNames()

getCollectorNames

Returns:

a Set object.

getLoggingCategory

public static String getLoggingCategory()

getCollectableServiceCount

public long getCollectableServiceCount()

setPollOutagesDao

public void setPollOutagesDao(ReadablePollOutagesDao pollOutagesDao)