org.opennms.netmgt.bsm.daemon

Class Bsmd

java.lang.Object

org.opennms.netmgt.bsm.daemon.Bsmd

All Implemented Interfaces:

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

public class Bsmd
extends Object
implements SpringServiceDaemon, BusinessServiceStateChangeHandler

This daemon is responsible for driving the Business Service state machine by: 1) Updating the state machine with Alarms when they are created, deleted or updated 2) Sending events on the event bus when the operational status of a Business Service changes 3) Reloading the Business Service configuration in the state machine when requested We currently listen for alarm life-cycle events in order to know when alarms change, but not all changes send the required events (i.e. escalating an alarm in the WebUI). In order to work around this, we periodically poll the database.

Author:

jwhite

Field Summary

Fields

Modifier and Type	Field and Description
protected static long	DEFAULT_POLL_INTERVAL
static String	NAME
protected static String	POLL_INTERVAL_KEY

Constructor Summary

Constructors

Constructor and Description
Bsmd()

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
void	destroy()
AlarmDao	getAlarmDao()
BusinessServiceStateMachine	getBusinessServiceStateMachine()
EventConfDao	getEventConfDao()
EventIpcManager	getEventIpcManager()
protected long	getPollInterval()
org.springframework.transaction.support.TransactionTemplate	getTransactionTemplate()
boolean	getVerifyReductionKeys()
void	handleAlarmLifecycleEvents(Event e)
void	handleBusinessServiceStateChanged(BusinessService businessService, Status newStatus, Status prevStatus) Called when the operational status of a business service was changed.
void	handleReloadEvent(Event e)
protected boolean	isAlarmPolling()
void	setAlarmDao(AlarmDao alarmDao)
void	setBusinessServiceStateMachine(BusinessServiceStateMachine stateMachine)
void	setEventConfDao(EventConfDao eventConfDao)
void	setEventIpcManager(EventIpcManager eventIpcManager)
void	setTransactionTemplate(org.springframework.transaction.support.TransactionTemplate template)
void	setVerifyReductionKeys(boolean verify)
void	start() start

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_POLL_INTERVAL

protected static final long DEFAULT_POLL_INTERVAL

See Also:

Constant Field Values

POLL_INTERVAL_KEY

protected static final String POLL_INTERVAL_KEY

See Also:

Constant Field Values

NAME

public static final String NAME

See Also:

Constant Field Values

Constructor Detail

Bsmd

public Bsmd()

Method Detail

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

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

Throws:

Exception

start

public void start()
           throws Exception

Description copied from interface: SpringServiceDaemon

start

Specified by:

start in interface SpringServiceDaemon

Throws:

Exception - if any.

isAlarmPolling

protected boolean isAlarmPolling()

getPollInterval

protected long getPollInterval()

handleAlarmLifecycleEvents

public void handleAlarmLifecycleEvents(Event e)

handleBusinessServiceStateChanged

public void handleBusinessServiceStateChanged(BusinessService businessService,
                                              Status newStatus,
                                              Status prevStatus)

Called when the operational status of a business service was changed.

Specified by:

handleBusinessServiceStateChanged in interface BusinessServiceStateChangeHandler

handleReloadEvent

public void handleReloadEvent(Event e)

destroy

public void destroy()
             throws Exception

Specified by:

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

Throws:

Exception

setAlarmDao

public void setAlarmDao(AlarmDao alarmDao)

getAlarmDao

public AlarmDao getAlarmDao()

setEventIpcManager

public void setEventIpcManager(EventIpcManager eventIpcManager)

getEventIpcManager

public EventIpcManager getEventIpcManager()

setEventConfDao

public void setEventConfDao(EventConfDao eventConfDao)

getEventConfDao

public EventConfDao getEventConfDao()

setTransactionTemplate

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

getTransactionTemplate

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

setVerifyReductionKeys

public void setVerifyReductionKeys(boolean verify)

getVerifyReductionKeys

public boolean getVerifyReductionKeys()

setBusinessServiceStateMachine

public void setBusinessServiceStateMachine(BusinessServiceStateMachine stateMachine)

getBusinessServiceStateMachine

public BusinessServiceStateMachine getBusinessServiceStateMachine()