org.opennms.netmgt.importer

Class BaseImporter

java.lang.Object

org.opennms.netmgt.importer.BaseImporter

All Implemented Interfaces:

ImportOperationFactory

Direct Known Subclasses:

ImporterService, ModelImporter

public class BaseImporter
extends Object
implements ImportOperationFactory

BaseImporter class.

Version:

$Id: $

Author:

ranger

Field Summary

Fields

Modifier and Type	Field and Description
protected DistPollerDao	m_distPollerDao
protected org.springframework.transaction.support.TransactionTemplate	m_transTemplate

Constructor Summary

Constructors

Constructor and Description
BaseImporter()

Method Summary

Methods

Modifier and Type	Method and Description
DeleteOperation	createDeleteOperation(Integer nodeId, String foreignSource, String foreignId) createDeleteOperation
protected ImportOperationsManager	createImportOperationsManager(Map<String,Integer> foreignIdsToNodes, ImportStatistics stats) createImportOperationsManager
InsertOperation	createInsertOperation(String foreignSource, String foreignId, String nodeLabel, String building, String city) createInsertOperation
UpdateOperation	createUpdateOperation(Integer nodeId, String foreignSource, String foreignId, String nodeLabel, String building, String city) createUpdateOperation
AssetRecordDao	getAssetRecordDao() getAssetRecordDao
CategoryDao	getCategoryDao() getCategoryDao
DistPollerDao	getDistPollerDao() getDistPollerDao
IpInterfaceDao	getIpInterfaceDao() getIpInterfaceDao
MonitoredServiceDao	getMonitoredServiceDao() getMonitoredServiceDao
NodeDao	getNodeDao() getNodeDao
int	getScanThreads() getScanThreads
ServiceTypeDao	getServiceTypeDao() getServiceTypeDao
org.springframework.transaction.support.TransactionTemplate	getTransTemplate() getTransTemplate
int	getWriteThreads() getWriteThreads
protected void	importModelFromResource(org.springframework.core.io.Resource resource) importModelFromResource
protected void	importModelFromResource(org.springframework.core.io.Resource resource, ImportStatistics stats, Event event) importModelFromResource
ThreadCategory	log() log
void	setAssetRecordDao(AssetRecordDao assetRecordDao) setAssetRecordDao
void	setCategoryDao(CategoryDao categoryDao) setCategoryDao
void	setDistPollerDao(DistPollerDao distPollerDao) setDistPollerDao
void	setIpInterfaceDao(IpInterfaceDao ipInterfaceDao) setIpInterfaceDao
void	setMonitoredServiceDao(MonitoredServiceDao monitoredServiceDao) setMonitoredServiceDao
void	setNodeDao(NodeDao nodeDao) setNodeDao
void	setScanThreads(int poolSize) setScanThreads
void	setServiceTypeDao(ServiceTypeDao serviceTypeDao) setServiceTypeDao
void	setTransactionTemplate(org.springframework.transaction.support.TransactionTemplate transTemplate) setTransactionTemplate
void	setTransTemplate(org.springframework.transaction.support.TransactionTemplate transTemplate) setTransTemplate
void	setWriteThreads(int writeThreads) setWriteThreads

Methods inherited from class java.lang.Object

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

Field Detail

m_transTemplate

protected org.springframework.transaction.support.TransactionTemplate m_transTemplate

m_distPollerDao

protected DistPollerDao m_distPollerDao

Constructor Detail

BaseImporter

public BaseImporter()

Method Detail

setTransactionTemplate

public void setTransactionTemplate(org.springframework.transaction.support.TransactionTemplate transTemplate)

setTransactionTemplate

Parameters:

transTemplate - a TransactionTemplate object.

getDistPollerDao

public DistPollerDao getDistPollerDao()

getDistPollerDao

Returns:

a DistPollerDao object.

setDistPollerDao

public void setDistPollerDao(DistPollerDao distPollerDao)

setDistPollerDao

Parameters:

distPollerDao - a DistPollerDao object.

getNodeDao

public NodeDao getNodeDao()

getNodeDao

Returns:

a NodeDao object.

setNodeDao

public void setNodeDao(NodeDao nodeDao)

setNodeDao

Parameters:

nodeDao - a NodeDao object.

getIpInterfaceDao

public IpInterfaceDao getIpInterfaceDao()

getIpInterfaceDao

Returns:

a IpInterfaceDao object.

setIpInterfaceDao

public void setIpInterfaceDao(IpInterfaceDao ipInterfaceDao)

setIpInterfaceDao

Parameters:

ipInterfaceDao - a IpInterfaceDao object.

getMonitoredServiceDao

public MonitoredServiceDao getMonitoredServiceDao()

getMonitoredServiceDao

Returns:

a MonitoredServiceDao object.

setMonitoredServiceDao

public void setMonitoredServiceDao(MonitoredServiceDao monitoredServiceDao)

setMonitoredServiceDao

Parameters:

monitoredServiceDao - a MonitoredServiceDao object.

getServiceTypeDao

public ServiceTypeDao getServiceTypeDao()

getServiceTypeDao

Returns:

a ServiceTypeDao object.

setServiceTypeDao

public void setServiceTypeDao(ServiceTypeDao serviceTypeDao)

setServiceTypeDao

Parameters:

serviceTypeDao - a ServiceTypeDao object.

getAssetRecordDao

public AssetRecordDao getAssetRecordDao()

getAssetRecordDao

Returns:

a AssetRecordDao object.

setAssetRecordDao

public void setAssetRecordDao(AssetRecordDao assetRecordDao)

setAssetRecordDao

Parameters:

assetRecordDao - a AssetRecordDao object.

getTransTemplate

public org.springframework.transaction.support.TransactionTemplate getTransTemplate()

getTransTemplate

Returns:

a TransactionTemplate object.

setTransTemplate

public void setTransTemplate(org.springframework.transaction.support.TransactionTemplate transTemplate)

setTransTemplate

Parameters:

transTemplate - a TransactionTemplate object.

createInsertOperation

public InsertOperation createInsertOperation(String foreignSource,
                                    String foreignId,
                                    String nodeLabel,
                                    String building,
                                    String city)

createInsertOperation

Specified by:

createInsertOperation in interface ImportOperationFactory

Parameters:

foreignSource - a String object.

foreignId - a String object.

nodeLabel - a String object.

building - a String object.

city - a String object.

Returns:

a InsertOperation object.

createUpdateOperation

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

createUpdateOperation

Specified by:

createUpdateOperation in interface ImportOperationFactory

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.

Returns:

a UpdateOperation object.

createDeleteOperation

public DeleteOperation createDeleteOperation(Integer nodeId,
                                    String foreignSource,
                                    String foreignId)

createDeleteOperation

Specified by:

createDeleteOperation in interface ImportOperationFactory

Parameters:

nodeId - a Integer object.

foreignSource - a String object.

foreignId - a String object.

Returns:

a DeleteOperation object.

importModelFromResource

protected void importModelFromResource(org.springframework.core.io.Resource resource)
                                throws IOException,
                                       ModelImportException

importModelFromResource

Parameters:

resource - a Resource object.

Throws:

IOException - if any.

ModelImportException - if any.

importModelFromResource

protected void importModelFromResource(org.springframework.core.io.Resource resource,
                           ImportStatistics stats,
                           Event event)
                                throws IOException,
                                       ModelImportException

importModelFromResource

Parameters:

resource - a Resource object.

stats - a ImportStatistics object.

event - a Event object.

Throws:

IOException - if any.

ModelImportException - if any.

createImportOperationsManager

protected ImportOperationsManager createImportOperationsManager(Map<String,Integer> foreignIdsToNodes,
                                                    ImportStatistics stats)

createImportOperationsManager

Parameters:

foreignIdsToNodes - a Map object.

stats - a ImportStatistics object.

Returns:

a ImportOperationsManager object.

log

public ThreadCategory log()

log

Returns:

a ThreadCategory object.

getCategoryDao

public CategoryDao getCategoryDao()

getCategoryDao

Returns:

a CategoryDao object.

setCategoryDao

public void setCategoryDao(CategoryDao categoryDao)

setCategoryDao

Parameters:

categoryDao - a CategoryDao object.

getScanThreads

public int getScanThreads()

getScanThreads

Returns:

a int.

setScanThreads

public void setScanThreads(int poolSize)

setScanThreads

Parameters:

poolSize - a int.

getWriteThreads

public int getWriteThreads()

getWriteThreads

Returns:

a int.

setWriteThreads

public void setWriteThreads(int writeThreads)

setWriteThreads

Parameters:

writeThreads - a int.