konark.manager
Class BasicMonitoringAgent

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

All Implemented Interfaces:

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

Direct Known Subclasses:

MonitoringAgent

public abstract class BasicMonitoringAgent

extends ajanta.agent.Agent

implements Subscriber

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, java.lang.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() The arrive method obtains a reference to the calendar database object of the the current server using the getResource primitive.
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()
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	startEventMachinery()
void	stopAgent()
void	subscribeEvent(java.lang.String eventClassName, ajanta.naming.URN subscriber)
void	subscribeEvent(java.lang.String eventClassName, ajanta.naming.URN subscriber, java.util.Hashtable filterTable)
void	switchOffPrintRunningThreads()
void	unsubscribeEvent(java.lang.String eventClassName, ajanta.naming.URN subscriber)
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

Methods inherited from interface konark.manager.Subscriber

addSubscription, removeSubscription, report, resubscribe

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,
                            java.lang.Boolean ifSql)

Parameters:

cred -

defSubscriber -

ifSql -

Method Detail

arrive

public void arrive()

The arrive method obtains a reference to the calendar database object of the the current server using the getResource primitive.

depart

public void depart()

stopAgent

public void stopAgent()
               throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

startEventMachinery

public void startEventMachinery()

executeBeforeRun

protected void executeBeforeRun()

Over ridden in Monitoring Agent

run

public void run()

viewEventTable

public void viewEventTable()

unsubscribeEvent

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

Specified by:

unsubscribeEvent in interface Subscriber

Throws:

java.rmi.RemoteException

remoteConfigException

subscribeEvent

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

Specified by:

subscribeEvent in interface Subscriber

Throws:

java.rmi.RemoteException

remoteConfigException

subscribeEvent

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

Specified by:

subscribeEvent in interface Subscriber

Parameters:

eventClassName -

subscriber -

Throws:

java.rmi.RemoteException

remoteConfigException

deleteEvent

public void deleteEvent(java.lang.String eventName)

Parameters:

eventName -

removeDetector

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

Parameters:

detector -

Throws:

java.rmi.RemoteException

addEvent

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

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

Throws:

java.rmi.RemoteException

java.rmi.AlreadyBoundException

restoreDetector

public void restoreDetector(EventDetector detector,
                            EventHandler handler)

Parameters:

detector -

handler -

addSubscriber

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

Parameters:

eventName -

subscriberList -

Throws:

java.rmi.RemoteException

addEventHandler

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

Parameters:

eventName -

eh -

addEventDetector

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

Parameters:

eventName -

ed -

replaceEventDetector

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

Parameters:

eventName -

ed -

replaceEventHandler

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

Parameters:

eventName -

eh -

deleteSubscriber

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

Parameters:

eventName -

subscriberList -

deleteSubscriber

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

Parameters:

eventName -

subscriber -

handlerAction

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

Parameters:

event -

Throws:

java.lang.Exception

showSubscribers

public void showSubscribers()

modifyDetector

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

Parameters:

userInput -

objectList -

Throws:

java.rmi.RemoteException

setAlarmLevel

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

Parameters:

eventClassName -

alarmLevel -

setAlertLevel

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

Parameters:

eventClassName -

alertLevel -

getDefaultSubscriber

public ajanta.naming.URN getDefaultSubscriber()

addOldSynchornizerObjects

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

printRunningThreads

public void printRunningThreads()

switchOffPrintRunningThreads

public void switchOffPrintRunningThreads()

getEventIDGenerator

public EventIDGenerator getEventIDGenerator()

Returns:

the unique event id generator for the agent

addHandlerPostAction

public abstract void addHandlerPostAction(EventHandler handler)