org.opennms.netmgt.linkd

Class HibernateEventWriter

java.lang.Object

org.opennms.netmgt.linkd.AbstractQueryManager

org.opennms.netmgt.linkd.HibernateEventWriter

All Implemented Interfaces:

QueryManager, org.springframework.beans.factory.InitializingBean

public class HibernateEventWriter
extends AbstractQueryManager
implements org.springframework.beans.factory.InitializingBean

Field Summary

Fields inherited from class org.opennms.netmgt.linkd.AbstractQueryManager

m_linkd

Fields inherited from interface org.opennms.netmgt.linkd.QueryManager

SNMP_DOT1D_FDB_STATUS_INVALID, SNMP_DOT1D_FDB_STATUS_LEARNED, SNMP_DOT1D_FDB_STATUS_MGMT, SNMP_DOT1D_FDB_STATUS_OTHER, SNMP_DOT1D_FDB_STATUS_SELF, SNMP_IF_TYPE_ETHERNET, SNMP_IF_TYPE_L2_VLAN, SNMP_IF_TYPE_L3_VLAN, SNMP_IF_TYPE_PROP_VIRTUAL

Constructor Summary

Constructors

Constructor and Description
HibernateEventWriter()

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
protected void	deleteOlderData(Date scanTime, int nodeid)
AtInterfaceDao	getAtInterfaceDao()
DataLinkInterfaceDao	getDataLinkInterfaceDao()
protected OnmsSnmpInterface	getFromSysnameAgentCircuitId(String lldpRemSysname, String lldpRemPortid)
protected OnmsSnmpInterface	getFromSysnameIfAlias(String lldpRemSysname, String lldpRemPortid)
protected OnmsSnmpInterface	getFromSysnameIfIndex(String lldpRemSysname, Integer lldpRemPortid)
protected OnmsSnmpInterface	getFromSysnameIfName(String lldpRemSysname, String lldpRemPortid)
OnmsSnmpInterface	getFromSysnameIpAddress(String lldpRemSysname, InetAddress lldpRemPortid)
protected OnmsSnmpInterface	getFromSysnameMacAddress(String lldpRemSysname, String lldpRemPortid)
protected OnmsSnmpInterface	getFromSysnamePortComponent(String lldpRemSysname, String lldpRemPortid)
protected int	getIfIndexByName(int targetCdpNodeId, String cdpTargetDevicePort)
IpInterfaceDao	getIpInterfaceDao()
IpRouteInterfaceDao	getIpRouteInterfaceDao()
NodeDao	getNodeDao()
protected List<OnmsNode>	getNodeidFromIp(InetAddress cdpTargetIpAddr)
protected Map<Integer,String>	getPhysAddrs(int nodeId)
protected List<RouterInterface>	getRouteInterface(InetAddress nexthop, int ifindex)
protected int	getSnmpIfType(int nodeId, Integer ifIndex)
SnmpInterfaceDao	getSnmpInterfaceDao()
LinkableSnmpNode	getSnmpNode(int nodeid) getSnmpNode
List<LinkableSnmpNode>	getSnmpNodeList() getSnmpNodeList
StpInterfaceDao	getStpInterfaceDao()
StpNodeDao	getStpNodeDao()
VlanDao	getVlanDao()
protected void	markOldDataInactive(Date scanTime, int nodeid)
protected void	saveAtInterface(OnmsAtInterface saveMe)
protected void	saveIpRouteInterface(OnmsIpRouteInterface saveMe)
protected void	saveStpInterface(OnmsStpInterface saveMe)
protected void	saveStpNode(OnmsStpNode saveMe)
protected void	saveVlan(OnmsVlan saveMe)
void	setDataLinkInterfaceDao(DataLinkInterfaceDao dataLinkInterfaceDao)
void	storeDiscoveryLink(DiscoveryLink discoveryLink) storeDiscoveryLink
LinkableNode	storeSnmpCollection(LinkableNode node, SnmpCollection snmpColl) storeSnmpCollection
void	update(int nodeid, OnmsArpInterface.StatusType action) update
void	updateDeletedNodes() updateDeletedNodes
void	updateForInterface(int nodeid, String ipAddr, int ifIndex, OnmsArpInterface.StatusType action) updateForInterface

Methods inherited from class org.opennms.netmgt.linkd.AbstractQueryManager

getIfIndex, getLinkd, getNode, getOnmsStpNode, processCdp, processDot1DBasePortTable, processDot1DTpFdbTable, processDot1StpPortTable, processIpNetToMediaTable, processIsis, processLldp, processOspf, processQBridgeDot1dTpFdbTable, processRouteTable, processVlanTable, processWifi, sendNewSuspectEvent, setLinkd, storeSnmpVlanCollection

Methods inherited from class java.lang.Object

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

Constructor Detail

HibernateEventWriter

public HibernateEventWriter()

Method Detail

getSnmpNodeList

public List<LinkableSnmpNode> getSnmpNodeList()

Description copied from interface: QueryManager

getSnmpNodeList

Specified by:

getSnmpNodeList in interface QueryManager

Returns:

a List object.

getSnmpNode

public LinkableSnmpNode getSnmpNode(int nodeid)

Description copied from interface: QueryManager

getSnmpNode

Specified by:

getSnmpNode in interface QueryManager

Parameters:

nodeid - a int.

Returns:

a LinkableNode object.

updateDeletedNodes

public void updateDeletedNodes()

Description copied from interface: QueryManager

updateDeletedNodes

Specified by:

updateDeletedNodes in interface QueryManager

markOldDataInactive

protected void markOldDataInactive(Date scanTime,
                                   int nodeid)

Specified by:

markOldDataInactive in class AbstractQueryManager

deleteOlderData

protected void deleteOlderData(Date scanTime,
                               int nodeid)

Specified by:

deleteOlderData in class AbstractQueryManager

storeSnmpCollection

@Transactional
public LinkableNode storeSnmpCollection(LinkableNode node,
                                                       SnmpCollection snmpColl)

Description copied from interface: QueryManager

storeSnmpCollection

Specified by:

storeSnmpCollection in interface QueryManager

Parameters:

node - a LinkableNode object.

snmpColl - a SnmpCollection object.

Returns:

a LinkableNode object.

storeDiscoveryLink

@Transactional
public void storeDiscoveryLink(DiscoveryLink discoveryLink)

Description copied from interface: QueryManager

storeDiscoveryLink

Specified by:

storeDiscoveryLink in interface QueryManager

Parameters:

discoveryLink - a DiscoveryLink object.

update

public void update(int nodeid,
                   OnmsArpInterface.StatusType action)

Description copied from interface: QueryManager

update

Specified by:

update in interface QueryManager

Parameters:

nodeid - a int.

action - a char.

updateForInterface

public void updateForInterface(int nodeid,
                               String ipAddr,
                               int ifIndex,
                               OnmsArpInterface.StatusType action)

Description copied from interface: QueryManager

updateForInterface

Specified by:

updateForInterface in interface QueryManager

Parameters:

nodeid - a int.

ipAddr - a String object.

ifIndex - a int.

action - a char.

getIfIndexByName

protected int getIfIndexByName(int targetCdpNodeId,
                               String cdpTargetDevicePort)

Specified by:

getIfIndexByName in class AbstractQueryManager

getNodeidFromIp

protected List<OnmsNode> getNodeidFromIp(InetAddress cdpTargetIpAddr)

Specified by:

getNodeidFromIp in class AbstractQueryManager

getRouteInterface

protected List<RouterInterface> getRouteInterface(InetAddress nexthop,
                                                  int ifindex)

Specified by:

getRouteInterface in class AbstractQueryManager

getSnmpIfType

protected int getSnmpIfType(int nodeId,
                            Integer ifIndex)

Specified by:

getSnmpIfType in class AbstractQueryManager

getPhysAddrs

protected Map<Integer,String> getPhysAddrs(int nodeId)

Specified by:

getPhysAddrs in class AbstractQueryManager

saveIpRouteInterface

protected void saveIpRouteInterface(OnmsIpRouteInterface saveMe)

Specified by:

saveIpRouteInterface in class AbstractQueryManager

saveVlan

protected void saveVlan(OnmsVlan saveMe)

Specified by:

saveVlan in class AbstractQueryManager

saveStpNode

protected void saveStpNode(OnmsStpNode saveMe)

Specified by:

saveStpNode in class AbstractQueryManager

saveStpInterface

protected void saveStpInterface(OnmsStpInterface saveMe)

Specified by:

saveStpInterface in class AbstractQueryManager

saveAtInterface

protected void saveAtInterface(OnmsAtInterface saveMe)

Specified by:

saveAtInterface in class AbstractQueryManager

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

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

Throws:

Exception

getNodeDao

public NodeDao getNodeDao()

Specified by:

getNodeDao in class AbstractQueryManager

getIpInterfaceDao

public IpInterfaceDao getIpInterfaceDao()

Specified by:

getIpInterfaceDao in class AbstractQueryManager

getSnmpInterfaceDao

public SnmpInterfaceDao getSnmpInterfaceDao()

Specified by:

getSnmpInterfaceDao in class AbstractQueryManager

getAtInterfaceDao

public AtInterfaceDao getAtInterfaceDao()

Specified by:

getAtInterfaceDao in class AbstractQueryManager

getVlanDao

public VlanDao getVlanDao()

getStpNodeDao

public StpNodeDao getStpNodeDao()

getStpInterfaceDao

public StpInterfaceDao getStpInterfaceDao()

getIpRouteInterfaceDao

public IpRouteInterfaceDao getIpRouteInterfaceDao()

getDataLinkInterfaceDao

public DataLinkInterfaceDao getDataLinkInterfaceDao()

setDataLinkInterfaceDao

public void setDataLinkInterfaceDao(DataLinkInterfaceDao dataLinkInterfaceDao)

getFromSysnameIpAddress

@Transactional
public OnmsSnmpInterface getFromSysnameIpAddress(String lldpRemSysname,
                                                                InetAddress lldpRemPortid)

Specified by:

getFromSysnameIpAddress in class AbstractQueryManager

getFromSysnameIfName

@Transactional
protected OnmsSnmpInterface getFromSysnameIfName(String lldpRemSysname,
                                                                String lldpRemPortid)

Specified by:

getFromSysnameIfName in class AbstractQueryManager

getFromSysnameIfIndex

@Transactional
protected OnmsSnmpInterface getFromSysnameIfIndex(String lldpRemSysname,
                                                                 Integer lldpRemPortid)

Specified by:

getFromSysnameIfIndex in class AbstractQueryManager

getFromSysnameMacAddress

@Transactional
protected OnmsSnmpInterface getFromSysnameMacAddress(String lldpRemSysname,
                                                                    String lldpRemPortid)

Specified by:

getFromSysnameMacAddress in class AbstractQueryManager

getFromSysnameIfAlias

@Transactional
protected OnmsSnmpInterface getFromSysnameIfAlias(String lldpRemSysname,
                                                                 String lldpRemPortid)

Specified by:

getFromSysnameIfAlias in class AbstractQueryManager

getFromSysnameAgentCircuitId

@Transactional
protected OnmsSnmpInterface getFromSysnameAgentCircuitId(String lldpRemSysname,
                                                                        String lldpRemPortid)

Specified by:

getFromSysnameAgentCircuitId in class AbstractQueryManager

getFromSysnamePortComponent

protected OnmsSnmpInterface getFromSysnamePortComponent(String lldpRemSysname,
                                                        String lldpRemPortid)

Specified by:

getFromSysnamePortComponent in class AbstractQueryManager