konark.manager
Class MonitoringAgent

java.lang.Object
  ajanta.agent.Agent
      konark.manager.BasicMonitoringAgent
          konark.manager.MonitoringAgent

All Implemented Interfaces:

Monitor, java.rmi.Remote, java.io.Serializable, Subscriber

Direct Known Subclasses:

SMSAgent

public class MonitoringAgent

extends BasicMonitoringAgent

implements Monitor

See Also:

Serialized Form

Field Summary

protected java.lang.String	dbpasswd
protected java.lang.String	dburl
protected java.lang.String	dbuser
protected java.util.Hashtable	listOfEventSubscribers
protected java.util.Vector	monitoringEvents
protected java.util.Hashtable	monitoringInfo
OutstandingMonList	outstandingMonList

Fields inherited from class konark.manager.BasicMonitoringAgent

dbModule, defaultSubscriber, eventIDGenerator, eventTable, keepRunning, localTriggerTable, remoteTriggerTable, reportedEventList, sql, subscriberHashtable

Fields inherited from class ajanta.agent.Agent

creatorSignature, cred, host, myRef, name, ownerSignature, status

Constructor Summary

MonitoringAgent(ajanta.agent.Credentials cred)

MonitoringAgent(ajanta.agent.Credentials cred, java.util.Hashtable monInfo, java.lang.String dburl, java.lang.String dbuser, java.lang.String dbpasswd, java.lang.Boolean ifSql, ajanta.naming.URN defSubURN)

Method Summary

void	addHandlerPostAction(EventHandler handler)
void	addSubscription(java.util.Vector eventList, ajanta.naming.URN agentURN) if you want to just subscribe again to outstanding monitors, you can specify eventList=null and agentURN=null
java.lang.Object	createObject(java.lang.String name)
void	executeBeforeRun() Over ridden in Monitoring Agent
protected void	handlerAction(Event event)
void	removeSubscription(ajanta.naming.URN monitorURN, java.lang.String event)
void	report(Event event)
void	resubscribe(ajanta.naming.URN monitorURN)
void	startEventMachinery()

Methods inherited from class konark.manager.BasicMonitoringAgent

addEvent, addEvent, addEventDetector, addEventHandler, addOldSynchornizerObjects, addSubscriber, arrive, deleteEvent, deleteSubscriber, deleteSubscriber, depart, getDefaultSubscriber, getEventIDGenerator, modifyDetector, printRunningThreads, removeDetector, replaceEventDetector, replaceEventHandler, restoreDetector, run, setAlarmLevel, setAlertLevel, showSubscribers, stopAgent, subscribeEvent, subscribeEvent, switchOffPrintRunningThreads, unsubscribeEvent, viewEventTable

Methods inherited from class ajanta.agent.Agent

agentEntry, agentExit, colocate, colocate, meet, recallCommand, signCreator, signOwner, start

Methods inherited from class java.lang.Object

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

Methods inherited from interface konark.manager.Monitor

addEvent, addEvent, addEventDetector, addEventHandler, addSubscriber, deleteEvent, deleteSubscriber, modifyDetector, printRunningThreads, removeDetector, replaceEventDetector, replaceEventHandler, restoreDetector, setAlarmLevel, setAlertLevel, stopAgent, switchOffPrintRunningThreads

Methods inherited from interface konark.manager.Subscriber

subscribeEvent, subscribeEvent, unsubscribeEvent

Field Detail

monitoringInfo

protected java.util.Hashtable monitoringInfo

listOfEventSubscribers

protected java.util.Hashtable listOfEventSubscribers

monitoringEvents

protected java.util.Vector monitoringEvents

dbpasswd

protected java.lang.String dbpasswd

dbuser

protected java.lang.String dbuser

dburl

protected java.lang.String dburl

outstandingMonList

public OutstandingMonList outstandingMonList

Constructor Detail

MonitoringAgent

public MonitoringAgent(ajanta.agent.Credentials cred)

Parameters:

cred -

MonitoringAgent

public MonitoringAgent(ajanta.agent.Credentials cred,
                       java.util.Hashtable monInfo,
                       java.lang.String dburl,
                       java.lang.String dbuser,
                       java.lang.String dbpasswd,
                       java.lang.Boolean ifSql,
                       ajanta.naming.URN defSubURN)

Parameters:

cred -

monInfo -

dburl -

dbuser -

dbpasswd -

ifSql -

defSubURN -

Method Detail

addSubscription

public void addSubscription(java.util.Vector eventList,
                            ajanta.naming.URN agentURN)
                     throws java.rmi.RemoteException,
                            remoteConfigException

if you want to just subscribe again to outstanding monitors, you can specify eventList=null and agentURN=null

Specified by:

addSubscription in interface Subscriber

Parameters:

eventList -

Throws:

java.rmi.RemoteException

remoteConfigException

removeSubscription

public void removeSubscription(ajanta.naming.URN monitorURN,
                               java.lang.String event)
                        throws java.rmi.RemoteException

Specified by:

removeSubscription in interface Subscriber

Throws:

java.rmi.RemoteException

startEventMachinery

public void startEventMachinery()

Overrides:

startEventMachinery in class BasicMonitoringAgent

executeBeforeRun

public void executeBeforeRun()

Description copied from class: BasicMonitoringAgent

Over ridden in Monitoring Agent

Overrides:

executeBeforeRun in class BasicMonitoringAgent

report

public void report(Event event)
            throws java.rmi.RemoteException

Specified by:

report in interface Subscriber

Parameters:

event -

Throws:

java.rmi.RemoteException

createObject

public java.lang.Object createObject(java.lang.String name)

Parameters:

name -

handlerAction

protected void handlerAction(Event event)
                      throws java.lang.Exception

Overrides:

handlerAction in class BasicMonitoringAgent

Parameters:

event -

Throws:

java.lang.Exception

resubscribe

public void resubscribe(ajanta.naming.URN monitorURN)
                 throws java.rmi.RemoteException

Specified by:

resubscribe in interface Subscriber

Throws:

java.rmi.RemoteException

addHandlerPostAction

public void addHandlerPostAction(EventHandler handler)

Specified by:

addHandlerPostAction in class BasicMonitoringAgent