|
OpenNMS API 1.1.3 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.opennms.netmgt.poller.BroadcastEventProcessor
Field Summary | |
private java.util.Map |
m_monitors
The map of service names to service models. |
private java.util.List |
m_pollableServices
List of PollableService objects. |
private Scheduler |
m_scheduler
The scheduler assocated with this reciever |
private boolean |
m_xmlrpc
Boolean flag to indicate if need to notify external xmlrpc server with event processing failure. |
private static java.lang.String |
SQL_COUNT_IFSERVICE_STATUS
SQL statement used to query the 'ifServices' for a nodeid/ipaddr/service combination on the receipt of a 'nodeGainedService' to make sure there is atleast one row where the service status for the tuple is 'A'. |
private static java.lang.String |
SQL_COUNT_IFSERVICES_TO_POLL
SQL statement used to count the active ifservices on the specified ip address. |
private static java.lang.String |
SQL_DELETE_SNMP_OUTAGE
SQL statement used to delete oustanding SNMP service outages for the specified nodeid/interface in the event in the event of a primary snmp interface changed event. |
private static java.lang.String |
SQL_FETCH_IFSERVICES_TO_POLL
SQL statement used to retrieve an active ifservice for the scheduler to poll. |
private static java.lang.String |
SQL_RETRIEVE_NODE_ID
SQL statement used to retrieve nodeid from the database for a specified ip address. |
private static int |
WAIT_FOREVER
Integer constant for passing in to PollableNode.getNodeLock() method in order to indicate that the method should block until node lock is available. |
Constructor Summary | |
(package private) |
BroadcastEventProcessor(java.util.List pollableServices)
Constructor |
Method Summary | |
void |
close()
Unsubscribe from eventd |
private void |
createMessageSelectorAndSubscribe()
Create message selector to set to the subscription |
java.lang.String |
getName()
Return an id for this event listener |
private void |
interfaceDeletedHandler(Event event)
|
private void |
interfaceReparentedHandler(Event event)
This method is responsible for processing 'interfacReparented' events. |
private void |
nodeDeletedHandler(Event event)
This method is responsible for removing the node specified in the nodeDeleted event from the Poller's pollable node map. |
private void |
nodeGainedServiceHandler(Event event)
Process the event, construct a new PollableService object representing the node/interface/service/pkg combination, and schedule the service for polling. |
private void |
nodeRemovePollableServiceHandler(Event event)
This method is responsible for removing a node's pollable service from the pollable services list |
void |
onEvent(Event event)
This method is invoked by the EventIpcManager when a new event is available for processing. |
private void |
restartPollingInterfaceHandler(Event event)
Process the event, construct new PollableService object representing the node/interface/service/pkg combination, and schedule all services on the specified interface for polling. |
private void |
serviceDeletedHandler(Event event)
This method remove a deleted service from the pollable service list of the specified interface, so that it will not be scheduled by the poller. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
private static java.lang.String SQL_DELETE_SNMP_OUTAGE
private static java.lang.String SQL_COUNT_IFSERVICE_STATUS
private static java.lang.String SQL_COUNT_IFSERVICES_TO_POLL
private static java.lang.String SQL_FETCH_IFSERVICES_TO_POLL
private static java.lang.String SQL_RETRIEVE_NODE_ID
private static int WAIT_FOREVER
private java.util.Map m_monitors
private Scheduler m_scheduler
private java.util.List m_pollableServices
private boolean m_xmlrpc
Constructor Detail |
BroadcastEventProcessor(java.util.List pollableServices)
pollableServices
- List of all the PollableService objects
scheduled for pollingMethod Detail |
private void createMessageSelectorAndSubscribe()
private void nodeGainedServiceHandler(Event event)
event
- The event to process.private void restartPollingInterfaceHandler(Event event)
event
- The event to process.private void interfaceReparentedHandler(Event event)
event
- The event to process.private void nodeRemovePollableServiceHandler(Event event)
private void nodeDeletedHandler(Event event)
private void interfaceDeletedHandler(Event event)
private void serviceDeletedHandler(Event event)
This method remove a deleted service from the pollable service list of the specified interface, so that it will not be scheduled by the poller.
public void close()
public void onEvent(Event event)
onEvent
in interface EventListener
event
- The eventpublic java.lang.String getName()
getName
in interface EventListener
|
OpenNMS API 1.1.3 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |