org.opennms.netmgt.perspectivepoller

Class PerspectivePollerd

java.lang.Object

org.opennms.netmgt.perspectivepoller.PerspectivePollerd

All Implemented Interfaces:

SpringServiceDaemon, PerspectiveServiceTracker.Listener, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean

public class PerspectivePollerd
extends Object
implements SpringServiceDaemon, PerspectiveServiceTracker.Listener

Field Summary

Fields

Modifier and Type	Field and Description
static String	LOG_PREFIX
static String	NAME

Constructor Summary

Constructors

Constructor and Description

PerspectivePollerd(SessionUtils sessionUtils, MonitoringLocationDao monitoringLocationDao, PollerConfig pollerConfig, MonitoredServiceDao monitoredServiceDao, LocationAwarePollerClient locationAwarePollerClient, ApplicationDao applicationDao, CollectionAgentFactory collectionAgentFactory, PersisterFactory persisterFactory, EventForwarder eventForwarder, ThresholdingService thresholdingService, EventDao eventDao, OutageDao outageDao, TracerRegistry tracerRegistry, PerspectiveServiceTracker tracker)

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
static org.quartz.JobKey	buildJobKey(int nodeId, InetAddress ipAddress, String serviceName, String perspectiveLocation)
static org.quartz.JobKey	buildJobKey(PerspectiveServiceTracker.ServicePerspectiveRef servicePerspective)
void	destroy()
LocationAwarePollerClient	getLocationAwarePollerClient()
void	handlePerspectiveNodeGainedService(IEvent e)
void	handlePerspectiveNodeLostService(IEvent e)
void	handleReloadDaemonConfig(IEvent event)
void	onServicePerspectiveAdded(PerspectiveServiceTracker.ServicePerspectiveRef servicePerspective, ServicePerspective entity)
void	onServicePerspectiveRemoved(PerspectiveServiceTracker.ServicePerspectiveRef servicePerspective)
void	persistResponseTimeData(PerspectivePolledService polledService, PollStatus pollStatus)
protected void	reportResult(PerspectivePolledService polledService, PollStatus pollResult)
void	start() start

Methods inherited from class java.lang.Object

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

Field Detail

NAME

public static final String NAME

See Also:

Constant Field Values

LOG_PREFIX

public static final String LOG_PREFIX

See Also:

Constant Field Values

Constructor Detail

PerspectivePollerd

@Autowired
public PerspectivePollerd(SessionUtils sessionUtils,
                                     MonitoringLocationDao monitoringLocationDao,
                                     PollerConfig pollerConfig,
                                     MonitoredServiceDao monitoredServiceDao,
                                     LocationAwarePollerClient locationAwarePollerClient,
                                     ApplicationDao applicationDao,
                                     CollectionAgentFactory collectionAgentFactory,
                                     PersisterFactory persisterFactory,
                                     EventForwarder eventForwarder,
                                     ThresholdingService thresholdingService,
                                     EventDao eventDao,
                                     OutageDao outageDao,
                                     TracerRegistry tracerRegistry,
                                     PerspectiveServiceTracker tracker)

Method Detail

start

public void start()
           throws Exception

Description copied from interface: SpringServiceDaemon

start

Specified by:

start in interface SpringServiceDaemon

Throws:

Exception - if any.

destroy

public void destroy()
             throws Exception

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Throws:

Exception

onServicePerspectiveAdded

public void onServicePerspectiveAdded(PerspectiveServiceTracker.ServicePerspectiveRef servicePerspective,
                                      ServicePerspective entity)

Specified by:

onServicePerspectiveAdded in interface PerspectiveServiceTracker.Listener

onServicePerspectiveRemoved

public void onServicePerspectiveRemoved(PerspectiveServiceTracker.ServicePerspectiveRef servicePerspective)

Specified by:

onServicePerspectiveRemoved in interface PerspectiveServiceTracker.Listener

buildJobKey

public static org.quartz.JobKey buildJobKey(PerspectiveServiceTracker.ServicePerspectiveRef servicePerspective)

buildJobKey

public static org.quartz.JobKey buildJobKey(int nodeId,
                                            InetAddress ipAddress,
                                            String serviceName,
                                            String perspectiveLocation)

getLocationAwarePollerClient

public LocationAwarePollerClient getLocationAwarePollerClient()

reportResult

protected void reportResult(PerspectivePolledService polledService,
                            PollStatus pollResult)

persistResponseTimeData

public void persistResponseTimeData(PerspectivePolledService polledService,
                                    PollStatus pollStatus)

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

Exception

handleReloadDaemonConfig

public void handleReloadDaemonConfig(IEvent event)

handlePerspectiveNodeLostService

public void handlePerspectiveNodeLostService(IEvent e)

handlePerspectiveNodeGainedService

public void handlePerspectiveNodeGainedService(IEvent e)