Package org.opennms.netmgt.provision.service

Class Provisioner

java.lang.Object

org.opennms.netmgt.provision.service.Provisioner

All Implemented Interfaces:

SpringServiceDaemon, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean

public class Provisioner
extends Object
implements SpringServiceDaemon

Massively Parallel Java Provisioning ServiceDaemon for OpenNMS.

Author:

Mathew Brozowski

Field Summary

Fields

Modifier and Type	Field	Description
static String	NAME	Constant NAME="Provisiond"

Constructor Summary

Constructors

Constructor	Description
Provisioner()

Method Summary

Modifier and Type	Method	Description
protected void	addToScheduleQueue(NodeScanSchedule schedule)	addToScheduleQueue
void	afterPropertiesSet()	afterPropertiesSet
protected void	checkNodeListForRemovals(List<NodeScanSchedule> schedules)	checkNodeListForRemovals
ForceRescanScan	createForceRescanScan(Integer nodeId, String monitorKey)	createForceRescanScan
NewSuspectScan	createNewSuspectScan(InetAddress ipAddress, String foreignSource, String location, String monitorKey)	createNewSuspectScan
NodeScan	createNodeScan(Integer nodeId, String foreignSource, String foreignId, OnmsMonitoringLocation location, String monitorKey)	createNodeScan
void	destroy()	destroy
void	doImport(String url, String rescanExisting, ProvisionMonitor monitor)	doImport
void	doImport(IEvent event)	Begins importing from resource specified in model-importer.properties file or in event parameter: url.
protected String	getEventForeignSource(Event event)	getEventForeignSource
EventForwarder	getEventForwarder()	getEventForwarder
ImportScheduler	getImportSchedule()	getImportSchedule
MonitoringSystemDao	getMonitoringSystemDao()
ExecutorService	getNewSuspectExecutor()
ProvisionService	getProvisionService()	getProvisionService
ScheduledFuture<?>	getScheduledFutureForNode(int nodeId)	getScheduledFutureForNode
int	getScheduleLength()	getScheduleLength
void	handleAddNode(IEvent event)	handleAddNode
void	handleDeleteInterface(IEvent event)	handleDeleteInterface
void	handleDeleteNode(IEvent event)	handleDeleteNode
void	handleDeleteService(IEvent event)	handleDeleteService
void	handleForceRescan(IEvent e)	handleForceRescan
void	handleNewSuspectEvent(IEvent event)
void	handleNodeAddedEvent(IEvent e)	handleNodeAddedEvent
void	handleNodeDeletedEvent(IEvent e)	handleNodeDeletedEvent
void	handleNodeUpdated(IEvent e)	handleNodeUpdated
void	handleReloadConfigEvent(IEvent e)	handleReloadConfigEvent
protected void	importModelFromResource(org.springframework.core.io.Resource resource, String rescanExisting)	importModelFromResource
protected RequisitionImport	importModelFromResource(org.springframework.core.io.Resource resource, String rescanExisting, ProvisionMonitor monitor)	importModelFromResource
protected void	removeFromScheduleQueue(List<Integer> nodeIds)	removeFromScheduleQueue
protected void	removeNodeFromScheduleQueue(Integer nodeId)	removeNodeFromScheduleQueue
protected void	scheduleRescanForExistingNodes(String monitorKey)	scheduleRescanForExistingNodes
void	setAgentConfigFactory(SnmpAgentConfigFactory agentConfigFactory)	setAgentConfigFactory
void	setEventForwarder(EventForwarder eventForwarder)	setEventForwarder
void	setImportActivities(CoreImportActivities importActivities)	setImportActivities
void	setImportSchedule(ImportScheduler schedule)	setImportSchedule
void	setLifeCycleRepository(LifeCycleRepository lifeCycleRepository)	setLifeCycleRepository
void	setMonitoringSystemDao(MonitoringSystemDao monitoringSystemDao)
void	setProvisionService(ProvisionService provisionService)	setProvisionService
void	setScheduledExecutor(ScheduledExecutorService scheduledExecutor)	setScheduledExecutor
void	setTaskCoordinator(TaskCoordinator taskCoordinator)	setTaskCoordinator
void	setTracerRegistry(TracerRegistry tracerRegistry)
void	start()	start
protected void	updateNodeScheduleInQueue(NodeScanSchedule schedule)	updateNodeScheduleInQueue
void	waitFor()

Methods inherited from class java.lang.Object

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

Field Detail

NAME

public static final String NAME

Constant NAME="Provisiond"

See Also:

Constant Field Values

Constructor Detail

Provisioner

public Provisioner()

Method Detail

setProvisionService

public void setProvisionService(ProvisionService provisionService)

setProvisionService

Parameters:

provisionService - a ProvisionService object.

getProvisionService

public ProvisionService getProvisionService()

getProvisionService

Returns:

a ProvisionService object.

setScheduledExecutor

public void setScheduledExecutor(ScheduledExecutorService scheduledExecutor)

setScheduledExecutor

Parameters:

scheduledExecutor - a ScheduledExecutorService object.

setLifeCycleRepository

public void setLifeCycleRepository(LifeCycleRepository lifeCycleRepository)

setLifeCycleRepository

Parameters:

lifeCycleRepository - a LifeCycleRepository object.

setImportSchedule

public void setImportSchedule(ImportScheduler schedule)

setImportSchedule

Parameters:

schedule - a ImportScheduler object.

setImportActivities

public void setImportActivities(CoreImportActivities importActivities)

setImportActivities

Parameters:

importActivities - the importActivities to set

setTaskCoordinator

public void setTaskCoordinator(TaskCoordinator taskCoordinator)

setTaskCoordinator

Parameters:

taskCoordinator - the taskCoordinator to set

setAgentConfigFactory

public void setAgentConfigFactory(SnmpAgentConfigFactory agentConfigFactory)

setAgentConfigFactory

Parameters:

agentConfigFactory - the agentConfigFactory to set

getImportSchedule

public ImportScheduler getImportSchedule()

getImportSchedule

Returns:

a ImportScheduler object.

getMonitoringSystemDao

public MonitoringSystemDao getMonitoringSystemDao()

setMonitoringSystemDao

public void setMonitoringSystemDao(MonitoringSystemDao monitoringSystemDao)

setTracerRegistry

public void setTracerRegistry(TracerRegistry tracerRegistry)

start

public void start()
           throws Exception

start

Specified by:

start in interface SpringServiceDaemon

Throws:

Exception - if any.

destroy

public void destroy()
             throws Exception

destroy

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Throws:

Exception - if any.

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

afterPropertiesSet

Specified by:

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

Throws:

Exception - if any.

scheduleRescanForExistingNodes

protected void scheduleRescanForExistingNodes(String monitorKey)

scheduleRescanForExistingNodes

createNodeScan

public NodeScan createNodeScan(Integer nodeId,
                               String foreignSource,
                               String foreignId,
                               OnmsMonitoringLocation location,
                               String monitorKey)

createNodeScan

Parameters:

nodeId - a Integer object.

foreignSource - a String object.

foreignId - a String object.

location - a OnmsMonitoringLocation object.

Returns:

a NodeScan object.

createNewSuspectScan

public NewSuspectScan createNewSuspectScan(InetAddress ipAddress,
                                           String foreignSource,
                                           String location,
                                           String monitorKey)

createNewSuspectScan

Parameters:

ipAddress - a InetAddress object.

Returns:

a NewSuspectScan object.

createForceRescanScan

public ForceRescanScan createForceRescanScan(Integer nodeId,
                                             String monitorKey)

createForceRescanScan

Parameters:

nodeId - a nodeId

Returns:

a ForceRescanScan object.

addToScheduleQueue

protected void addToScheduleQueue(NodeScanSchedule schedule)

addToScheduleQueue

Parameters:

schedule - a NodeScanSchedule object.

updateNodeScheduleInQueue

protected void updateNodeScheduleInQueue(NodeScanSchedule schedule)

updateNodeScheduleInQueue

Parameters:

schedule - a NodeScanSchedule object.

getScheduledFutureForNode

public ScheduledFuture<?> getScheduledFutureForNode(int nodeId)

getScheduledFutureForNode

Parameters:

nodeId - a int.

Returns:

a ScheduledFuture object.

removeNodeFromScheduleQueue

protected void removeNodeFromScheduleQueue(Integer nodeId)

removeNodeFromScheduleQueue

Parameters:

nodeId - a Integer object.

removeFromScheduleQueue

protected void removeFromScheduleQueue(List<Integer> nodeIds)

removeFromScheduleQueue

Parameters:

nodeIds - a List object.

checkNodeListForRemovals

protected void checkNodeListForRemovals(List<NodeScanSchedule> schedules)

checkNodeListForRemovals

Parameters:

schedules - a List object.

getScheduleLength

public int getScheduleLength()

getScheduleLength

Returns:

a int.

importModelFromResource

protected void importModelFromResource(org.springframework.core.io.Resource resource,
                                       String rescanExisting)
                                throws Exception

importModelFromResource

Parameters:

resource - a Resource object.

rescanExisting - a String object - Valid values are "true", "false" and "dbonly".

Throws:

Exception - if any.

importModelFromResource

protected RequisitionImport importModelFromResource(org.springframework.core.io.Resource resource,
                                                    String rescanExisting,
                                                    ProvisionMonitor monitor)
                                             throws Exception

importModelFromResource

Parameters:

resource - a Resource object.

rescanExisting - a String object - Valid values are "true", "false" and "dbonly".

monitor - a ProvisionMonitor object.

Returns:

the imported requesition

Throws:

Exception - if any.

setEventForwarder

public void setEventForwarder(EventForwarder eventForwarder)

setEventForwarder

Parameters:

eventForwarder - a EventForwarder object.

getEventForwarder

public EventForwarder getEventForwarder()

getEventForwarder

Returns:

a EventForwarder object.

doImport

public void doImport(IEvent event)
              throws ExecutionException

Begins importing from resource specified in model-importer.properties file or in event parameter: url. Import Resources are managed with a "key" called "foreignSource" specified in the XML retrieved by the resource and can be overridden as a parameter of an event.

Parameters:

event - a IEvent object.

Throws:

ExecutionException

doImport

public void doImport(String url,
                     String rescanExisting,
                     ProvisionMonitor monitor)

doImport

Parameters:

url - a String object.

handleNodeAddedEvent

public void handleNodeAddedEvent(IEvent e)

handleNodeAddedEvent

Parameters:

e - a IEvent object.

handleForceRescan

public void handleForceRescan(IEvent e)

handleForceRescan

Parameters:

e - a IEvent object.

handleNewSuspectEvent

public void handleNewSuspectEvent(IEvent event)

handleNodeUpdated

public void handleNodeUpdated(IEvent e)

handleNodeUpdated

A re-import has occurred, attempt a rescan now.

Parameters:

e - a IEvent object.

handleNodeDeletedEvent

public void handleNodeDeletedEvent(IEvent e)

handleNodeDeletedEvent

Parameters:

e - a IEvent object.

handleReloadConfigEvent

public void handleReloadConfigEvent(IEvent e)

handleReloadConfigEvent

Parameters:

e - a IEvent object.

handleAddNode

public void handleAddNode(IEvent event)

handleAddNode

Parameters:

event - a IEvent object.

handleDeleteInterface

public void handleDeleteInterface(IEvent event)

handleDeleteInterface

Parameters:

event - a IEvent object.

handleDeleteNode

public void handleDeleteNode(IEvent event)

handleDeleteNode

Parameters:

event - a IEvent object.

handleDeleteService

public void handleDeleteService(IEvent event)

handleDeleteService

Parameters:

event - a IEvent object.

getEventForeignSource

protected String getEventForeignSource(Event event)

getEventForeignSource

Parameters:

event - a Event object.

Returns:

a String object.

waitFor

public void waitFor()

getNewSuspectExecutor

public ExecutorService getNewSuspectExecutor()