|
OpenNMS API 1.2.3 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.opennms.netmgt.eventd.Eventd
Eventd listens for events from the discovery, capsd, trapd processes and sends events to the Master Station when queried for.
Eventd receives events sent in as XML, looks up the event.conf and adds information to these events and stores them to the db. It also reconverts them back to XML to be sent to other processes like 'actiond'
Process like trapd, capsd etc. that are local to the distributed poller send events to the eventd. Events can also be sent via TCP or UDP to eventd.
Eventd listens for incoming events, loads info from the 'event.conf', adds events to the database and sends the events added to the database to subscribed listeners. It also maintains a servicename to serviceid mapping from the services table so as to prevent a database lookup for each incoming event
The number of threads that processes events is configurable via the eventd configuration xml
Field Summary | |
static java.lang.String |
LOG4J_CATEGORY
The log4j category used to log debug messsages and statements. |
private java.lang.String |
m_address
Contains dotted-decimal representation of the IP address where Eventd is running. |
private static java.util.Map |
m_serviceTableMap
The service table map |
private static Eventd |
m_singleton
Singleton instance of this class |
private int |
m_status
The current status of this fiber |
private EventReceiver |
m_tcpReceiver
The handler for events coming in through TCP |
private EventReceiver |
m_udpReceiver
The handler for events coming in through UDP |
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 | |
Eventd()
Constuctor creates the localhost address(to be used eventually when eventd originates events during correlation) and the broadcast queue |
Method Summary | |
static void |
addServiceMapping(java.lang.String svcname,
int serviceid)
Add the svcname/svcid mapping to the servicetable map |
static Eventd |
getInstance()
|
java.lang.String |
getLocalHostAddress()
Used to retrieve the local host address. |
java.lang.String |
getName()
Returns a name/id for this process |
static int |
getServiceID(java.lang.String svcname)
Return the service id for the name passed |
int |
getStatus()
Returns the current status |
void |
init()
|
void |
pause()
Pauses all the threads |
boolean |
processEvent(Event event)
|
void |
receiptSent(EventReceipt event)
|
void |
resume()
Resumes all the threads |
void |
start()
Read the eventd configuration xml, create and start all the subthreads |
void |
stop()
Stops all the eventd threads |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
public static final java.lang.String LOG4J_CATEGORY
private static final Eventd m_singleton
private static java.util.Map m_serviceTableMap
private EventReceiver m_tcpReceiver
private EventReceiver m_udpReceiver
private java.lang.String m_address
Contains dotted-decimal representation of the IP address where Eventd is running. Used when eventd sends events out
private int m_status
Constructor Detail |
public Eventd()
Method Detail |
public void stop()
stop
in interface Fiber
public java.lang.String getName()
getName
in interface Fiber
Fiber
.public int getStatus()
getStatus
in interface Fiber
Fiber
.public void init()
public void start()
start
in interface Fiber
public void pause()
pause
in interface PausableFiber
public void resume()
resume
in interface PausableFiber
public java.lang.String getLocalHostAddress()
public static int getServiceID(java.lang.String svcname)
svcname
- the service name whose service id is required
public static void addServiceMapping(java.lang.String svcname, int serviceid)
public static Eventd getInstance()
public boolean processEvent(Event event)
processEvent
in interface EventHandler
public void receiptSent(EventReceipt event)
receiptSent
in interface EventHandler
|
OpenNMS API 1.2.3 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |