org.opennms.netmgt.importer.operations
Class AbstractSaveOrUpdateOperation

java.lang.Object
  org.opennms.netmgt.importer.operations.AbstractImportOperation
      org.opennms.netmgt.importer.operations.AbstractSaveOrUpdateOperation

All Implemented Interfaces:

ImportOperation, SaveOrUpdateOperation

Direct Known Subclasses:

InsertOperation, UpdateOperation

public abstract class AbstractSaveOrUpdateOperation
extends AbstractImportOperation
implements SaveOrUpdateOperation

Abstract AbstractSaveOrUpdateOperation class.

Version:

$Id: $

Author:

ranger

Constructor Summary

AbstractSaveOrUpdateOperation(Integer nodeId, String foreignSource, String foreignId, String nodeLabel, String building, String city)
Constructor for AbstractSaveOrUpdateOperation.

AbstractSaveOrUpdateOperation(String foreignSource, String foreignId, String nodeLabel, String building, String city)
Constructor for AbstractSaveOrUpdateOperation.

Method Summary

protected abstract List<Event>	doPersist() doPersist
void	foundAsset(String name, String value) foundAsset
void	foundCategory(String name) foundCategory
void	foundInterface(String ipAddr, Object descr, InterfaceSnmpPrimaryType snmpPrimary, boolean managed, int status) foundInterface
void	foundMonitoredService(String serviceName) foundMonitoredService
void	gatherAdditionalData() gatherAdditionalData
CategoryDao	getCategoryDao() getCategoryDao
protected DistPollerDao	getDistPollerDao() getDistPollerDao
protected Map<String,OnmsIpInterface>	getIpAddrToInterfaceMap(OnmsNode imported) getIpAddrToInterfaceMap
protected OnmsNode	getNode() getNode
protected NodeDao	getNodeDao() getNodeDao
protected boolean	isSnmpDataForInterfacesUpToDate() isSnmpDataForInterfacesUpToDate
protected boolean	isSnmpDataForNodeUpToDate() isSnmpDataForNodeUpToDate
protected ThreadCategory	log() log
boolean	nullSafeEquals(Object o1, Object o2) nullSafeEquals
List<Event>	persist() persist
void	setCategoryCache(ThreadLocal<HashMap<String,OnmsCategory>> categoryCache) setCategoryCache
void	setCategoryDao(CategoryDao categoryDao) setCategoryDao
void	setDistPollerDao(DistPollerDao distPollerDao) setDistPollerDao
void	setNodeDao(NodeDao nodeDao) setNodeDao
void	setServiceTypeDao(ServiceTypeDao svcTypeDao) setServiceTypeDao
void	setTypeCache(ThreadLocal<HashMap<String,OnmsServiceType>> typeCache) setTypeCache
protected void	updateSnmpData() updateSnmpData

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractSaveOrUpdateOperation

public AbstractSaveOrUpdateOperation(String foreignSource,
                                     String foreignId,
                                     String nodeLabel,
                                     String building,
                                     String city)

Constructor for AbstractSaveOrUpdateOperation.

Parameters:

foreignSource - a String object.

foreignId - a String object.

nodeLabel - a String object.

building - a String object.

city - a String object.

AbstractSaveOrUpdateOperation

public AbstractSaveOrUpdateOperation(Integer nodeId,
                                     String foreignSource,
                                     String foreignId,
                                     String nodeLabel,
                                     String building,
                                     String city)

Constructor for AbstractSaveOrUpdateOperation.

Parameters:

nodeId - a Integer object.

foreignSource - a String object.

foreignId - a String object.

nodeLabel - a String object.

building - a String object.

city - a String object.

Method Detail

foundInterface

public void foundInterface(String ipAddr,
                           Object descr,
                           InterfaceSnmpPrimaryType snmpPrimary,
                           boolean managed,
                           int status)

foundInterface

Specified by:

foundInterface in interface SaveOrUpdateOperation

Parameters:

ipAddr - a String object.

descr - a Object object.

snmpPrimary - a InterfaceSnmpPrimaryType object.

managed - a boolean.

status - a int.

gatherAdditionalData

public void gatherAdditionalData()

gatherAdditionalData

Specified by:

gatherAdditionalData in interface ImportOperation

persist

public List<Event> persist()

persist

Specified by:

persist in interface ImportOperation

Returns:

a List object.

doPersist

protected abstract List<Event> doPersist()

doPersist

Returns:

a List object.

updateSnmpData

protected void updateSnmpData()

updateSnmpData

isSnmpDataForNodeUpToDate

protected boolean isSnmpDataForNodeUpToDate()

isSnmpDataForNodeUpToDate

Returns:

a boolean.

isSnmpDataForInterfacesUpToDate

protected boolean isSnmpDataForInterfacesUpToDate()

isSnmpDataForInterfacesUpToDate

Returns:

a boolean.

foundMonitoredService

public void foundMonitoredService(String serviceName)

foundMonitoredService

Specified by:

foundMonitoredService in interface SaveOrUpdateOperation

Parameters:

serviceName - a String object.

foundCategory

public void foundCategory(String name)

foundCategory

Specified by:

foundCategory in interface SaveOrUpdateOperation

Parameters:

name - a String object.

foundAsset

public void foundAsset(String name,
                       String value)

foundAsset

Specified by:

foundAsset in interface SaveOrUpdateOperation

Parameters:

name - a String object.

value - a String object.

getNode

protected OnmsNode getNode()

getNode

Returns:

a OnmsNode object.

getNodeDao

protected NodeDao getNodeDao()

getNodeDao

Returns:

a NodeDao object.

getDistPollerDao

protected DistPollerDao getDistPollerDao()

getDistPollerDao

Returns:

a DistPollerDao object.

getIpAddrToInterfaceMap

protected Map<String,OnmsIpInterface> getIpAddrToInterfaceMap(OnmsNode imported)

getIpAddrToInterfaceMap

Parameters:

imported - a OnmsNode object.

Returns:

a Map object.

getCategoryDao

public CategoryDao getCategoryDao()

getCategoryDao

Returns:

a CategoryDao object.

setCategoryDao

public void setCategoryDao(CategoryDao categoryDao)

setCategoryDao

Parameters:

categoryDao - a CategoryDao object.

setServiceTypeDao

public void setServiceTypeDao(ServiceTypeDao svcTypeDao)

setServiceTypeDao

Parameters:

svcTypeDao - a ServiceTypeDao object.

setNodeDao

public void setNodeDao(NodeDao nodeDao)

setNodeDao

Parameters:

nodeDao - a NodeDao object.

setDistPollerDao

public void setDistPollerDao(DistPollerDao distPollerDao)

setDistPollerDao

Parameters:

distPollerDao - a DistPollerDao object.

setTypeCache

public void setTypeCache(ThreadLocal<HashMap<String,OnmsServiceType>> typeCache)

setTypeCache

Parameters:

typeCache - a ThreadLocal object.

setCategoryCache

public void setCategoryCache(ThreadLocal<HashMap<String,OnmsCategory>> categoryCache)

setCategoryCache

Parameters:

categoryCache - a ThreadLocal object.

log

protected ThreadCategory log()

log

Returns:

a ThreadCategory object.

nullSafeEquals

public boolean nullSafeEquals(Object o1,
                              Object o2)

nullSafeEquals

Parameters:

o1 - a Object object.

o2 - a Object object.

Returns:

a boolean.