org.opennms.netmgt.poller

Class Poller

java.lang.Object

org.opennms.netmgt.daemon.AbstractServiceDaemon

org.opennms.netmgt.poller.Poller

All Implemented Interfaces:

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

public class Poller
extends AbstractServiceDaemon

Poller 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
Poller() Constructor for Poller.

Method Summary

Modifier and Type	Method and Description
EventIpcManager	getEventIpcManager() getEventIpcManager
EventIpcManager	getEventManager() getEventManager
org.opennms.netmgt.poller.PollerEventProcessor	getEventProcessor() getEventProcessor
static String	getLoggingCategory()
PollableNetwork	getNetwork() getNetwork
long	getNumPolls() Returns the number of polls that have been executed so far.
PollerConfig	getPollerConfig() getPollerConfig
PollOutagesConfig	getPollOutagesConfig() getPollOutagesConfig
QueryManager	getQueryManager() getQueryManager
Scheduler	getScheduler() getScheduler
ServiceMonitor	getServiceMonitor(String svcName) getServiceMonitor
protected void	onInit() onInit
protected void	onPause() onPause
protected void	onResume() onResume
protected void	onStart() onStart
protected void	onStop() onStop
boolean	packageIncludesIfAndSvc(Package pkg, String ipAddr, String svcName) packageIncludesIfAndSvc
protected boolean	pollableServiceInPackage(String ipAddr, String serviceName, Package pkg) pollableServiceInPackage
void	refreshServicePackages() refreshServicePackages
void	refreshServiceThresholds() refreshServiceThresholds
void	scheduleService(int nodeId, String nodeLabel, String nodeLocation, String ipAddr, String svcName, PollableNode pollableNode) scheduleService
void	setEventIpcManager(EventIpcManager eventIpcManager) setEventIpcManager
void	setEventProcessor(org.opennms.netmgt.poller.PollerEventProcessor eventProcessor) setEventProcessor
void	setLocationAwarePollerClient(LocationAwarePollerClient locationAwarePollerClient)
void	setMonitoredServiceDao(MonitoredServiceDao monitoredServiceDao)
void	setNetwork(PollableNetwork network) setNetwork
void	setOutageDao(OutageDao outageDao)
void	setPersisterFactory(PersisterFactory persisterFactory)
void	setPollerConfig(PollerConfig pollerConfig) setPollerConfig
void	setPollOutagesConfig(PollOutagesConfig pollOutagesConfig) setPollOutagesConfig
void	setScheduler(LegacyScheduler scheduler) setScheduler
void	setTransactionTemplate(org.springframework.transaction.support.TransactionTemplate transactionTemplate)

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

Constructor Detail

Poller

public Poller()

Constructor for Poller.

Method Detail

setPersisterFactory

public void setPersisterFactory(PersisterFactory persisterFactory)

setOutageDao

public void setOutageDao(OutageDao outageDao)

setMonitoredServiceDao

public void setMonitoredServiceDao(MonitoredServiceDao monitoredServiceDao)

setTransactionTemplate

public void setTransactionTemplate(org.springframework.transaction.support.TransactionTemplate transactionTemplate)

setEventIpcManager

public void setEventIpcManager(EventIpcManager eventIpcManager)

setEventIpcManager

Parameters:

eventIpcManager - a org.opennms.netmgt.model.events.EventIpcManager object.

getEventIpcManager

public EventIpcManager getEventIpcManager()

getEventIpcManager

Returns:

a org.opennms.netmgt.model.events.EventIpcManager object.

getEventManager

public EventIpcManager getEventManager()

getEventManager

Returns:

a EventIpcManager object.

getEventProcessor

public org.opennms.netmgt.poller.PollerEventProcessor getEventProcessor()

getEventProcessor

Returns:

a PollerEventProcessor object.

setEventProcessor

public void setEventProcessor(org.opennms.netmgt.poller.PollerEventProcessor eventProcessor)

setEventProcessor

Parameters:

eventProcessor - a PollerEventProcessor object.

getNetwork

public PollableNetwork getNetwork()

getNetwork

Returns:

a PollableNetwork object.

setNetwork

public void setNetwork(PollableNetwork network)

setNetwork

Parameters:

network - a PollableNetwork object.

getQueryManager

public QueryManager getQueryManager()

getQueryManager

Returns:

a QueryManager object.

getPollerConfig

public PollerConfig getPollerConfig()

getPollerConfig

Returns:

a PollerConfig object.

setPollerConfig

public void setPollerConfig(PollerConfig pollerConfig)

setPollerConfig

Parameters:

pollerConfig - a PollerConfig object.

getPollOutagesConfig

public PollOutagesConfig getPollOutagesConfig()

getPollOutagesConfig

Returns:

a PollOutagesConfig object.

setPollOutagesConfig

public void setPollOutagesConfig(PollOutagesConfig pollOutagesConfig)

setPollOutagesConfig

Parameters:

pollOutagesConfig - a PollOutagesConfig object.

getScheduler

public Scheduler getScheduler()

getScheduler

Returns:

a Scheduler object.

setScheduler

public void setScheduler(LegacyScheduler scheduler)

setScheduler

Parameters:

scheduler - a LegacyScheduler object.

setLocationAwarePollerClient

public void setLocationAwarePollerClient(LocationAwarePollerClient locationAwarePollerClient)

onInit

protected void onInit()

onInit

Specified by:

onInit in class AbstractServiceDaemon

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

getServiceMonitor

public ServiceMonitor getServiceMonitor(String svcName)

getServiceMonitor

Parameters:

svcName - a String object.

Returns:

a ServiceMonitor object.

scheduleService

public void scheduleService(int nodeId,
                            String nodeLabel,
                            String nodeLocation,
                            String ipAddr,
                            String svcName,
                            PollableNode pollableNode)

scheduleService

Parameters:

nodeId - a int.

nodeLabel - a String object.

nodeLocation - a String object.

ipAddr - a String object.

svcName - a String object.

pollableNode - a PollableNode object

pollableServiceInPackage

protected boolean pollableServiceInPackage(String ipAddr,
                                           String serviceName,
                                           Package pkg)

pollableServiceInPackage

Parameters:

ipAddr - a String object.

serviceName - a String object.

pkg - a Package object.

Returns:

a boolean.

packageIncludesIfAndSvc

public boolean packageIncludesIfAndSvc(Package pkg,
                                       String ipAddr,
                                       String svcName)

packageIncludesIfAndSvc

Parameters:

pkg - a Package object.

ipAddr - a String object.

svcName - a String object.

Returns:

a boolean.

refreshServicePackages

public void refreshServicePackages()

refreshServicePackages

refreshServiceThresholds

public void refreshServiceThresholds()

refreshServiceThresholds

getNumPolls

public long getNumPolls()

Returns the number of polls that have been executed so far.

Returns:

the number of polls that have been executed

getLoggingCategory

public static String getLoggingCategory()