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.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

Poller()
Constructor for Poller.

Method Summary

void	closeOutagesForInterface(Date closeDate, int eventId, int nodeId, String ipAddr) closeOutagesForInterface
void	closeOutagesForNode(Date closeDate, int eventId, int nodeId) closeOutagesForNode
void	closeOutagesForService(Date closeDate, int eventId, int nodeId, String ipAddr, String serviceName) closeOutagesForService
EventIpcManager	getEventManager() getEventManager
org.opennms.netmgt.poller.PollerEventProcessor	getEventProcessor() getEventProcessor
static Poller	getInstance() getInstance
PollableNetwork	getNetwork() getNetwork
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 ipAddr, String svcName) scheduleService
void	setDataSource(DataSource dataSource) setDataSource
void	setEventManager(EventIpcManager eventMgr) setEventManager
void	setEventProcessor(org.opennms.netmgt.poller.PollerEventProcessor eventProcessor) setEventProcessor
void	setNetwork(PollableNetwork network) setNetwork
void	setPollerConfig(PollerConfig pollerConfig) setPollerConfig
void	setPollOutagesConfig(PollOutagesConfig pollOutagesConfig) setPollOutagesConfig
void	setQueryManager(QueryManager queryManager) setQueryManager
void	setScheduler(LegacyScheduler scheduler) setScheduler

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

afterPropertiesSet, debugf, debugf, errorf, errorf, fatalf, fatalf, getName, getStatus, getStatusText, infof, infof, init, isPaused, isRunning, isStarting, isStartPending, log, pause, resume, setStatus, start, status, stop, waitForStatus, waitForStatus, warnf, warnf

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

setDataSource

public void setDataSource(DataSource dataSource)

setDataSource

Parameters:

dataSource - a DataSource object.

getEventManager

public EventIpcManager getEventManager()

getEventManager

Returns:

a EventIpcManager object.

setEventManager

public void setEventManager(EventIpcManager eventMgr)

setEventManager

Parameters:

eventMgr - 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.

setQueryManager

public void setQueryManager(QueryManager queryManager)

setQueryManager

Parameters:

queryManager - a QueryManager 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.

onInit

protected void onInit()

onInit

Specified by:

onInit in class AbstractServiceDaemon

closeOutagesForNode

public void closeOutagesForNode(Date closeDate,
                                int eventId,
                                int nodeId)

closeOutagesForNode

Parameters:

closeDate - a Date object.

eventId - a int.

nodeId - a int.

closeOutagesForInterface

public void closeOutagesForInterface(Date closeDate,
                                     int eventId,
                                     int nodeId,
                                     String ipAddr)

closeOutagesForInterface

Parameters:

closeDate - a Date object.

eventId - a int.

nodeId - a int.

ipAddr - a String object.

closeOutagesForService

public void closeOutagesForService(Date closeDate,
                                   int eventId,
                                   int nodeId,
                                   String ipAddr,
                                   String serviceName)

closeOutagesForService

Parameters:

closeDate - a Date object.

eventId - a int.

nodeId - a int.

ipAddr - a String object.

serviceName - a String object.

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

getInstance

public static Poller getInstance()

getInstance

Returns:

a Poller object.

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 ipAddr,
                            String svcName)

scheduleService

Parameters:

nodeId - a int.

nodeLabel - a String object.

ipAddr - a String object.

svcName - a String 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