network.manager
Class BasicMonitoringAgent

java.lang.Object
  ajanta.agent.Agent
      network.manager.BasicMonitoringAgent

All Implemented Interfaces:

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

Direct Known Subclasses:

MonitoringAgent

public abstract class BasicMonitoringAgent

extends ajanta.agent.Agent

implements Monitor

See Also:

Serialized Form

Field Summary

protected DBModule	dbModule
protected ajanta.naming.URN	defaultSubscriber
protected EventIDGenerator	eventIDGenerator
protected EventTableSync	eventTable
protected boolean	keepRunning
protected java.util.Hashtable	listOfEventSubscribers
protected java.util.Hashtable	localTriggerTable
protected java.util.Hashtable	remoteTriggerTable
protected EventQueueSync	reportedEventList
protected boolean	sql
protected java.util.Hashtable	subscriberHashtable

Fields inherited from class ajanta.agent.Agent

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

Constructor Summary

BasicMonitoringAgent(ajanta.agent.Credentials cred)

BasicMonitoringAgent(ajanta.agent.Credentials cred, ajanta.naming.URN defSubscriber, boolean ifSql)

Method Summary

void	addEvent(EventDetector detector, EventHandler handler, java.util.Vector subscriberList)
void	addEvent(java.lang.String eventClassName, EventHandler handler, java.util.Vector subscriberList)
void	addEventDetector(java.lang.String eventName, EventDetector ed)
void	addEventHandler(java.lang.String eventName, EventHandler eh)
abstract void	addHandlerPostAction(EventHandler handler)
void	addOldSynchornizerObjects(java.lang.String eventClassName, java.util.Vector synchronizerObjectsVector)
void	addSubscriber(java.lang.String eventName, java.util.Vector subscriberList)
void	arrive()
void	deleteEvent(java.lang.String eventName)
void	deleteSubscriber(java.lang.String eventName, ajanta.naming.URN subscriber)
void	deleteSubscriber(java.lang.String eventName, java.util.Vector subscriberList)
void	depart()
protected void	executeBeforeRun() Over ridden in Monitoring Agent
ajanta.naming.URN	getDefaultSubscriber()
EventIDGenerator	getEventIDGenerator() returns the unique event id generator for the agent
protected void	handlerAction(Event event)
void	modifyDetector(java.lang.String userInput, java.lang.Object[] objectList)
void	printRunningThreads()
void	removeDetector(java.lang.String detector)
void	replaceEventDetector(java.lang.String eventName, EventDetector ed)
void	replaceEventHandler(java.lang.String eventName, EventHandler eh)
void	restoreDetector(EventDetector detector, EventHandler handler)
void	run()
void	setAlarmLevel(java.lang.String eventClassName, int alarmLevel)
void	setAlertLevel(java.lang.String eventClassName, int alertLevel)
void	showSubscribers()
void	stopAgent()
void	subscribeEvent(java.lang.String eventClassName, ajanta.naming.URN subscriber)
void	switchOffPrintRunningThreads()
void	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

Field Detail

eventTable

protected EventTableSync eventTable

reportedEventList

protected EventQueueSync reportedEventList

subscriberHashtable

protected java.util.Hashtable subscriberHashtable

localTriggerTable

protected java.util.Hashtable localTriggerTable

remoteTriggerTable

protected java.util.Hashtable remoteTriggerTable

listOfEventSubscribers

protected java.util.Hashtable listOfEventSubscribers

keepRunning

protected boolean keepRunning

dbModule

protected DBModule dbModule

defaultSubscriber

protected ajanta.naming.URN defaultSubscriber

sql

protected boolean sql

eventIDGenerator

protected EventIDGenerator eventIDGenerator

Constructor Detail

BasicMonitoringAgent

public BasicMonitoringAgent(ajanta.agent.Credentials cred)

BasicMonitoringAgent

public BasicMonitoringAgent(ajanta.agent.Credentials cred,
                            ajanta.naming.URN defSubscriber,
                            boolean ifSql)

Parameters:

cred -

defSubscriber -

ifSql -

Method Detail

arrive

public void arrive()

Returns:

depart

public void depart()

Returns:

stopAgent

public void stopAgent()
               throws java.rmi.RemoteException

Specified by:

stopAgent in interface Monitor

Returns:

Throws:

java.rmi.RemoteException

executeBeforeRun

protected void executeBeforeRun()

Over ridden in Monitoring Agent

run

public void run()

Returns:

viewEventTable

public void viewEventTable()

Returns:

subscribeEvent

public void subscribeEvent(java.lang.String eventClassName,
                           ajanta.naming.URN subscriber)
                    throws java.rmi.RemoteException,
                           remoteConfigException

Specified by:

subscribeEvent in interface Monitor

Parameters:

eventClassName -

subscriber -

Returns:

Throws:

java.rmi.RemoteException

remoteConfigException

deleteEvent

public void deleteEvent(java.lang.String eventName)

Specified by:

deleteEvent in interface Monitor

Parameters:

eventName -

Returns:

removeDetector

public void removeDetector(java.lang.String detector)
                    throws java.rmi.RemoteException

Specified by:

removeDetector in interface Monitor

Parameters:

detector -

Returns:

Throws:

java.rmi.RemoteException

addEvent

public void addEvent(EventDetector detector,
                     EventHandler handler,
                     java.util.Vector subscriberList)
              throws java.rmi.RemoteException,
                     java.rmi.AlreadyBoundException

Specified by:

addEvent in interface Monitor

Returns:

Throws:

java.rmi.RemoteException

java.rmi.AlreadyBoundException

addEvent

public void addEvent(java.lang.String eventClassName,
                     EventHandler handler,
                     java.util.Vector subscriberList)
              throws java.rmi.RemoteException,
                     java.rmi.AlreadyBoundException

Specified by:

addEvent in interface Monitor

Parameters:

eventClassName -

Returns:

Throws:

java.rmi.RemoteException

java.rmi.AlreadyBoundException

restoreDetector

public void restoreDetector(EventDetector detector,
                            EventHandler handler)

Specified by:

restoreDetector in interface Monitor

Parameters:

detector -

handler -

Returns:

addSubscriber

public void addSubscriber(java.lang.String eventName,
                          java.util.Vector subscriberList)
                   throws java.rmi.RemoteException

Specified by:

addSubscriber in interface Monitor

Parameters:

eventName -

subscriberList -

Returns:

Throws:

java.rmi.RemoteException

addEventHandler

public void addEventHandler(java.lang.String eventName,
                            EventHandler eh)

Specified by:

addEventHandler in interface Monitor

Parameters:

eventName -

eh -

Returns:

addEventDetector

public void addEventDetector(java.lang.String eventName,
                             EventDetector ed)

Specified by:

addEventDetector in interface Monitor

Parameters:

eventName -

ed -

Returns:

replaceEventDetector

public void replaceEventDetector(java.lang.String eventName,
                                 EventDetector ed)

Specified by:

replaceEventDetector in interface Monitor

Parameters:

eventName -

ed -

Returns:

replaceEventHandler

public void replaceEventHandler(java.lang.String eventName,
                                EventHandler eh)

Specified by:

replaceEventHandler in interface Monitor

Parameters:

eventName -

eh -

Returns:

deleteSubscriber

public void deleteSubscriber(java.lang.String eventName,
                             java.util.Vector subscriberList)

Specified by:

deleteSubscriber in interface Monitor

Parameters:

eventName -

subscriberList -

Returns:

deleteSubscriber

public void deleteSubscriber(java.lang.String eventName,
                             ajanta.naming.URN subscriber)

Parameters:

eventName -

subscriber -

Returns:

handlerAction

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

Parameters:

event -

Returns:

Throws:

java.lang.Exception

showSubscribers

public void showSubscribers()

Returns:

modifyDetector

public void modifyDetector(java.lang.String userInput,
                           java.lang.Object[] objectList)
                    throws java.rmi.RemoteException

Specified by:

modifyDetector in interface Monitor

Parameters:

userInput -

Returns:

Throws:

java.rmi.RemoteException

setAlarmLevel

public void setAlarmLevel(java.lang.String eventClassName,
                          int alarmLevel)

Specified by:

setAlarmLevel in interface Monitor

Parameters:

eventClassName -

alarmLevel -

Returns:

setAlertLevel

public void setAlertLevel(java.lang.String eventClassName,
                          int alertLevel)

Specified by:

setAlertLevel in interface Monitor

Parameters:

eventClassName -

alertLevel -

Returns:

getDefaultSubscriber

public ajanta.naming.URN getDefaultSubscriber()

Returns:

addOldSynchornizerObjects

public void addOldSynchornizerObjects(java.lang.String eventClassName,
                                      java.util.Vector synchronizerObjectsVector)

printRunningThreads

public void printRunningThreads()

Specified by:

printRunningThreads in interface Monitor

Returns:

switchOffPrintRunningThreads

public void switchOffPrintRunningThreads()

Specified by:

switchOffPrintRunningThreads in interface Monitor

Returns:

getEventIDGenerator

public EventIDGenerator getEventIDGenerator()

returns the unique event id generator for the agent

Returns:

addHandlerPostAction

public abstract void addHandlerPostAction(EventHandler handler)