network.manager
Class ItineraryAgent

java.lang.Object
  ajanta.agent.Agent
      ajanta.agent.ItinAgent
          network.manager.BasicItineraryAgent
              network.manager.ItineraryAgent

All Implemented Interfaces:

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

public class ItineraryAgent

extends BasicItineraryAgent

implements Subscriber

See Also:

Serialized Form

Field Summary

protected java.lang.String	dbpasswd
protected java.lang.String	dburl
protected java.lang.String	dbuser

Fields inherited from class network.manager.BasicItineraryAgent

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

Fields inherited from class ajanta.agent.ItinAgent

itin

Fields inherited from class ajanta.agent.Agent

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

Constructor Summary

ItineraryAgent(ajanta.agent.Credentials cred, java.util.Hashtable monInfo, java.lang.String dburl, java.lang.String dbuser, java.lang.String dbpasswd, boolean ifSql, ajanta.naming.URN defSubURN, ajanta.pattern.Itinerary itin)

ItineraryAgent(ajanta.agent.Credentials cred, ajanta.pattern.Itinerary itin)

Method Summary

void	addHandlerPostAction(EventHandler handler)
void	addSubscription(java.util.Vector eventList, ajanta.naming.URN agentURN)
static ajanta.pattern.Itinerary	createItinerary(ajanta.server.AgentEnv creatingHost, java.lang.String travelpattern, java.lang.String hostfile, int loopInterval) Function called by ConfigManager which supplies the file containing list of hosts.
java.lang.Object	createObject(java.lang.String name)
void	executeBeforeRun()
void	removeSubscription(ajanta.naming.URN monitorURN, java.lang.String event)
void	report(Event event)
void	resubscribe(ajanta.naming.URN monitorURN)
void	run()
void	startEventDetectorThread()
boolean	subscribe(java.util.Vector eventList, ajanta.naming.URN agURN)

Methods inherited from class network.manager.BasicItineraryAgent

addEvent, addEvent, addEventDetector, addEventHandler, addOldSynchornizerObjects, addSubscriber, deleteEvent, deleteSubscriber, deleteSubscriber, getDefaultSubscriber, getEventIDGenerator, handlerAction, modifyDetector, printRunningThreads, removeDetector, replaceEventDetector, replaceEventHandler, restoreDetector, setAlarmLevel, setAlertLevel, stopAgent, subscribeEvent, switchOffPrintRunningThreads

Methods inherited from class ajanta.agent.ItinAgent

arrive, checkDepartStatus, depart, getItinerary, noOp, setItinerary, start

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 network.manager.Monitor

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

Field Detail

dbpasswd

protected java.lang.String dbpasswd

dbuser

protected java.lang.String dbuser

dburl

protected java.lang.String dburl

Constructor Detail

ItineraryAgent

public ItineraryAgent(ajanta.agent.Credentials cred,
                      ajanta.pattern.Itinerary itin)

Parameters:

cred -

itin -

ItineraryAgent

public ItineraryAgent(ajanta.agent.Credentials cred,
                      java.util.Hashtable monInfo,
                      java.lang.String dburl,
                      java.lang.String dbuser,
                      java.lang.String dbpasswd,
                      boolean ifSql,
                      ajanta.naming.URN defSubURN,
                      ajanta.pattern.Itinerary itin)

Parameters:

cred -

monInfo -

dburl -

dbuser -

dbpasswd -

ifSql -

defSubURN -

Method Detail

createItinerary

public static ajanta.pattern.Itinerary createItinerary(ajanta.server.AgentEnv creatingHost,
                                                       java.lang.String travelpattern,
                                                       java.lang.String hostfile,
                                                       int loopInterval)
                                                throws java.lang.Exception

Function called by ConfigManager which supplies the file containing list of hosts. This function parses the host file, creates the itinerary file and creates the Itinerary object and returns it to ConfigManager.

Parameters:

hostfile -

loopInterval -

Throws:

java.lang.Exception

report

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

Specified by:

report in interface Subscriber

Parameters:

event -

Throws:

java.rmi.RemoteException

addSubscription

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

Specified by:

addSubscription in interface Subscriber

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

subscribe

public boolean subscribe(java.util.Vector eventList,
                         ajanta.naming.URN agURN)
                  throws remoteConfigException

Throws:

remoteConfigException

createObject

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

Parameters:

name -

Returns:

executeBeforeRun

public void executeBeforeRun()

Returns:

run

public void run()

startEventDetectorThread

public void startEventDetectorThread()

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 BasicItineraryAgent