public class Provisioner extends Object implements SpringServiceDaemon
ServiceDaemon
for OpenNMS.Modifier and Type | Field and Description |
---|---|
static String |
NAME
Constant
NAME="Provisiond" |
Constructor and Description |
---|
Provisioner() |
Modifier and Type | Method and Description |
---|---|
protected void |
addToScheduleQueue(NodeScanSchedule schedule)
addToScheduleQueue
|
void |
afterPropertiesSet()
afterPropertiesSet
|
protected void |
checkNodeListForRemovals(List<NodeScanSchedule> schedules)
checkNodeListForRemovals
|
ForceRescanScan |
createForceRescanScan(Integer nodeId)
createForceRescanScan
|
NewSuspectScan |
createNewSuspectScan(InetAddress ipAddress,
String foreignSource)
createNewSuspectScan
|
NodeScan |
createNodeScan(Integer nodeId,
String foreignSource,
String foreignId)
createNodeScan
|
void |
destroy()
destroy
|
void |
doImport()
doImport
|
void |
doImport(Event event)
Begins importing from resource specified in model-importer.properties file or
in event parameter: url.
|
void |
doImport(String url,
String rescanExisting)
doImport
|
void |
doNodeScan(int nodeId)
doNodeScan
|
protected String |
getEventForeignSource(Event event)
getEventForeignSource
|
EventForwarder |
getEventForwarder()
getEventForwarder
|
ImportScheduler |
getImportSchedule()
getImportSchedule
|
ProvisionService |
getProvisionService()
getProvisionService
|
ScheduledFuture<?> |
getScheduledFutureForNode(int nodeId)
getScheduledFutureForNode
|
int |
getScheduleLength()
getScheduleLength
|
String |
getStats()
getStats
|
void |
handleAddInterface(Event event)
handleAddInterface
|
void |
handleAddNode(Event event)
handleAddNode
|
void |
handleChangeService(Event event)
handleChangeService
|
void |
handleDeleteInterface(Event event)
handleDeleteInterface
|
void |
handleDeleteNode(Event event)
handleDeleteNode
|
void |
handleDeleteService(Event event)
handleDeleteService
|
void |
handleForceRescan(Event e)
handleForceRescan
|
void |
handleNewSuspectEvent(Event e)
handleNewSuspectEvent
|
void |
handleNodeAddedEvent(Event e)
handleNodeAddedEvent
|
void |
handleNodeDeletedEvent(Event e)
handleNodeDeletedEvent
|
void |
handleNodeUpdated(Event e)
handleNodeUpdated
|
void |
handleReloadConfigEvent(Event e)
handleReloadConfigEvent
|
void |
handleUpdateServer(Event event)
handleUpdateServer
|
void |
handleUpdateService(Event event)
handleUpdateService
|
protected void |
importModelFromResource(org.springframework.core.io.Resource resource,
String rescanExisting)
importModelFromResource
|
protected void |
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()
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 |
setProvisionService(ProvisionService provisionService)
setProvisionService
|
void |
setScheduledExecutor(ScheduledExecutorService scheduledExecutor)
setScheduledExecutor
|
void |
setTaskCoordinator(DefaultTaskCoordinator taskCoordinator)
setTaskCoordinator
|
void |
start()
start
|
protected void |
updateNodeScheduleInQueue(NodeScanSchedule schedule)
updateNodeScheduleInQueue
|
void |
waitFor() |
public static final String NAME
NAME="Provisiond"
public void setProvisionService(ProvisionService provisionService)
setProvisionService
provisionService
- a ProvisionService
object.public ProvisionService getProvisionService()
getProvisionService
ProvisionService
object.public void setScheduledExecutor(ScheduledExecutorService scheduledExecutor)
setScheduledExecutor
scheduledExecutor
- a ScheduledExecutorService
object.public void setLifeCycleRepository(LifeCycleRepository lifeCycleRepository)
setLifeCycleRepository
lifeCycleRepository
- a LifeCycleRepository
object.public void setImportSchedule(ImportScheduler schedule)
setImportSchedule
schedule
- a ImportScheduler
object.public void setImportActivities(CoreImportActivities importActivities)
setImportActivities
importActivities
- the importActivities to setpublic void setTaskCoordinator(DefaultTaskCoordinator taskCoordinator)
setTaskCoordinator
taskCoordinator
- the taskCoordinator to setpublic void setAgentConfigFactory(SnmpAgentConfigFactory agentConfigFactory)
setAgentConfigFactory
agentConfigFactory
- the agentConfigFactory to setpublic ImportScheduler getImportSchedule()
getImportSchedule
ImportScheduler
object.public void start() throws Exception
start
start
in interface SpringServiceDaemon
Exception
- if any.public void destroy() throws Exception
destroy
destroy
in interface org.springframework.beans.factory.DisposableBean
Exception
- if any.public void afterPropertiesSet() throws Exception
afterPropertiesSet
afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
Exception
- if any.protected void scheduleRescanForExistingNodes()
scheduleRescanForExistingNodes
public void doNodeScan(int nodeId) throws InterruptedException, ExecutionException
doNodeScan
nodeId
- a int.InterruptedException
- if any.ExecutionException
- if any.public NodeScan createNodeScan(Integer nodeId, String foreignSource, String foreignId)
createNodeScan
public NewSuspectScan createNewSuspectScan(InetAddress ipAddress, String foreignSource)
createNewSuspectScan
ipAddress
- a InetAddress
object.NewSuspectScan
object.public ForceRescanScan createForceRescanScan(Integer nodeId)
createForceRescanScan
ipAddress
- a InetAddress
object.ForceRescanScan
object.protected void addToScheduleQueue(NodeScanSchedule schedule)
addToScheduleQueue
schedule
- a NodeScanSchedule
object.protected void updateNodeScheduleInQueue(NodeScanSchedule schedule)
updateNodeScheduleInQueue
schedule
- a NodeScanSchedule
object.public ScheduledFuture<?> getScheduledFutureForNode(int nodeId)
getScheduledFutureForNode
nodeId
- a int.ScheduledFuture
object.protected void removeNodeFromScheduleQueue(Integer nodeId)
removeNodeFromScheduleQueue
nodeId
- a Integer
object.protected void removeFromScheduleQueue(List<Integer> nodeIds)
removeFromScheduleQueue
nodeIds
- a List
object.protected void checkNodeListForRemovals(List<NodeScanSchedule> schedules)
checkNodeListForRemovals
schedules
- a List
object.public int getScheduleLength()
getScheduleLength
protected void importModelFromResource(org.springframework.core.io.Resource resource, String rescanExisting) throws Exception
importModelFromResource
resource
- a Resource
object.rescanExisting
- TODOException
- if any.protected void importModelFromResource(org.springframework.core.io.Resource resource, String rescanExisting, ProvisionMonitor monitor) throws Exception
importModelFromResource
resource
- a Resource
object.rescanExisting
- TODOmonitor
- a ProvisionMonitor
object.Exception
- if any.public void setEventForwarder(EventForwarder eventForwarder)
setEventForwarder
eventForwarder
- a EventForwarder
object.public EventForwarder getEventForwarder()
getEventForwarder
EventForwarder
object.public void doImport()
doImport
public void doImport(Event event)
event
- a Event
object.public void doImport(String url, String rescanExisting)
doImport
url
- a String
object.public void handleNodeAddedEvent(Event e)
handleNodeAddedEvent
e
- a Event
object.public void handleForceRescan(Event e)
handleForceRescan
e
- a Event
object.public void handleNewSuspectEvent(Event e)
handleNewSuspectEvent
e
- a Event
object.public void handleNodeUpdated(Event e)
handleNodeUpdated
A re-import has occurred, attempt a rescan now.e
- a Event
object.public void handleNodeDeletedEvent(Event e)
handleNodeDeletedEvent
e
- a Event
object.public void handleReloadConfigEvent(Event e)
handleReloadConfigEvent
e
- a Event
object.public void handleAddInterface(Event event)
handleAddInterface
event
- a Event
object.public void handleAddNode(Event event)
handleAddNode
event
- a Event
object.public void handleChangeService(Event event)
handleChangeService
event
- a Event
object.public void handleDeleteInterface(Event event)
handleDeleteInterface
event
- a Event
object.public void handleDeleteNode(Event event)
handleDeleteNode
event
- a Event
object.public void handleDeleteService(Event event)
handleDeleteService
event
- a Event
object.public void handleUpdateServer(Event event)
handleUpdateServer
event
- a Event
object.public void handleUpdateService(Event event)
handleUpdateService
event
- a Event
object.public void waitFor()
Copyright © 2017. All rights reserved.