public class Trapd extends AbstractServiceDaemon implements PausableFiber, TrapProcessorFactory, TrapNotificationListener, org.springframework.beans.factory.InitializingBean
The Trapd listens for SNMP traps on the standard port(162). Creates a SnmpTrapSession and implements the SnmpTrapHandler to get callbacks when traps are received.
The received traps are converted into XML and sent to eventd.
Note: Trapd is a PausableFiber so as to receive control events. However, a 'pause' on Trapd has no impact on the receiving and processing of traps.
PAUSE_PENDING, PAUSED, RESUME_PENDING
RUNNING, START_PENDING, STARTING, STATUS_NAMES, STOP_PENDING, STOPPED
Constructor and Description |
---|
Trapd()
Constructs a new Trapd object that receives and forwards trap messages
via JSDT.
|
Modifier and Type | Method and Description |
---|---|
TrapProcessor |
createTrapProcessor()
createTrapProcessor
|
FifoQueue<TrapNotification> |
getBacklogQ()
getBacklogQ
|
BroadcastEventProcessor |
getEventReader()
getEventReader
|
org.opennms.netmgt.trapd.TrapQueueProcessor |
getProcessor()
getProcessor
|
String |
getSnmpTrapAddress() |
int |
getSnmpTrapPort()
getSnmpTrapPort
|
List<SnmpV3User> |
getSnmpV3Users() |
int |
getStatus()
Returns the current status of the service.
|
TrapdIpMgr |
getTrapdIpMgr()
getTrapdIpMgr
|
void |
onInit()
onInit
|
void |
onPause()
Pauses Trapd
|
void |
onResume()
Resumes Trapd
|
void |
onStart()
Create the SNMP trap session and create the communication channel
to communicate with eventd.
|
void |
onStop()
Stops the currently running service.
|
void |
setBacklogQ(FifoQueue<TrapNotification> backlogQ)
setBacklogQ
|
void |
setEventReader(BroadcastEventProcessor eventReader)
setEventReader
|
void |
setProcessor(org.opennms.netmgt.trapd.TrapQueueProcessor processor)
setProcessor
|
void |
setSnmpTrapAddress(String snmpTrapAddress) |
void |
setSnmpTrapPort(int snmpTrapPort)
setSnmpTrapPort
|
void |
setSnmpV3Users(List<SnmpV3User> snmpV3Users) |
void |
setTrapdIpMgr(TrapdIpMgr trapdIpMgr)
setTrapdIpMgr
|
void |
trapError(int error,
String msg) |
void |
trapReceived(TrapNotification trapNotification) |
afterPropertiesSet, debugf, debugf, errorf, errorf, fatalf, fatalf, getName, getStatusText, infof, infof, init, isPaused, isRunning, isStarting, isStartPending, log, pause, resume, setStatus, start, status, stop, waitForStatus, waitForStatus, warnf, warnf
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
pause, resume
public Trapd()
Constructs a new Trapd object that receives and forwards trap messages via JSDT. The session is initialized with the default client name of OpenNMS.trapd. The trap session is started on the default port, as defined by the SNMP library.
SnmpTrapSession
public TrapProcessor createTrapProcessor()
createTrapProcessor
createTrapProcessor
in interface TrapProcessorFactory
TrapProcessor
object.public void trapReceived(TrapNotification trapNotification)
trapReceived
in interface TrapNotificationListener
public void onInit()
onInit
onInit
in class AbstractServiceDaemon
public void onStart()
onStart
in class AbstractServiceDaemon
UndeclaredThrowableException
- if an unexpected database, or IO exception occurs.SnmpTrapSession
,
SnmpTrapHandler
public void onPause()
onPause
in class AbstractServiceDaemon
public void onResume()
onResume
in class AbstractServiceDaemon
public void onStop()
onStop
in class AbstractServiceDaemon
public int getStatus()
getStatus
in interface Fiber
getStatus
in class AbstractServiceDaemon
public void trapError(int error, String msg)
trapError
in interface TrapNotificationListener
public TrapdIpMgr getTrapdIpMgr()
getTrapdIpMgr
TrapdIpMgr
object.public void setTrapdIpMgr(TrapdIpMgr trapdIpMgr)
setTrapdIpMgr
trapdIpMgr
- a TrapdIpMgr
object.public BroadcastEventProcessor getEventReader()
getEventReader
BroadcastEventProcessor
object.public void setEventReader(BroadcastEventProcessor eventReader)
setEventReader
eventReader
- a BroadcastEventProcessor
object.public FifoQueue<TrapNotification> getBacklogQ()
getBacklogQ
FifoQueue
object.public void setBacklogQ(FifoQueue<TrapNotification> backlogQ)
setBacklogQ
backlogQ
- a FifoQueue
object.public org.opennms.netmgt.trapd.TrapQueueProcessor getProcessor()
getProcessor
TrapQueueProcessor
object.public void setProcessor(org.opennms.netmgt.trapd.TrapQueueProcessor processor)
setProcessor
processor
- a TrapQueueProcessor
object.public String getSnmpTrapAddress()
public void setSnmpTrapAddress(String snmpTrapAddress)
public int getSnmpTrapPort()
getSnmpTrapPort
public void setSnmpTrapPort(int snmpTrapPort)
setSnmpTrapPort
snmpTrapPort
- a int.public List<SnmpV3User> getSnmpV3Users()
public void setSnmpV3Users(List<SnmpV3User> snmpV3Users)
Copyright © 2015. All Rights Reserved.