public AutoMonitoringAgentImpl() throws RemoteException 
{
	super();
}

 public  void doBehavior() 
{
 waitUntilDeath();
}

 public  void doLocalCleanup() 
{
	
	super.doLocalCleanup();
	disconnectFrom( sla );
	try {
	    Enumeration cells = sla.listCells( this ).elements();
	    while( cells.hasMoreElements() ) {
		CellListInfo cli = (CellListInfo)cells.nextElement();
		if( cli.isUp() ) {
		    Debug.notice( "Asking to stop monitoring " + cli.getAddress() );
		    try {
			ama.stopMonitoringCell( this, cli.getAddress() );
		    } catch( RemoteException error ) {
			Debug.warning( "Remote exception while trying to ask the agent monitoring agent to stop monitoring " + cli.getAddress(), error ); 
		    }
		}
	    }
	} catch( RemoteException error ) {
	    Debug.warning( "Could not retrieve the list of cells which are up from the server list agent", error );
	}
}

 public  void doLocalSetup() throws AgentInitializationException 
{
	super.doLocalSetup();
	try {
	    String[] amaName = { "net.hivecell.hive.agent.cell.AgentMonitoringAgent" };
	    AgentSet ds = myCell.queryAgents( this, amaName, null );
	    ama = (AgentMonitoringAgent)ds.pickOne(); 
	    String[] slaName = { "net.hivecell.hive.agent.cell.CellListAgent" };
	    ds = myCell.queryAgents( this, slaName, null );
	    sla = (CellListAgent)ds.pickOne();
	    if( !connectTo( sla ) ) {  // subscribe to the event stream
		Debug.warning( "Could not subscribe to local server list agent" );
		myCell.killAgent( (AgentImpl)this );
	    }
	} catch( ClassNotFoundException error ) {
	    Debug.critical( "Huh?  This should -never- happen!!", error );
	}
	try {
	    Enumeration cells = sla.listCells( this ).elements();
	    while( cells.hasMoreElements() ) {
		CellListInfo cli = (CellListInfo)cells.nextElement();
		if( cli.isUp() ) {
		    try {
			ama.monitorCell( this, cli.getAddress() );
		    } catch( RemoteException error ) {
			Debug.warning( "Remote exception while trying to ask the agent monitoring agent to monitor " + cli.getAddress(), error ); 
		    } catch( UnableToMonitorCellException error ) {
			Debug.warning( "Agent monitoring agent unable to monitor cell at " + cli.getAddress(), error );
		    }
		}
	    }
	} catch( RemoteException error ) {
	    Debug.warning( "Could not retrieve the list of cells which are up from the server list agent", error );
	}
}

 public  void notify(HiveEvent event) 
{
	super.notify( event );
	if( !event.getSource().equals( sla ) ) {
	    Debug.warning( "Got an event from a source other than the server list agent (" + event.getSource() + ")...  Ignoring it." );
	    return;
	}
	if( !( event instanceof CellEvent ) ) {
	    Debug.warning( "The server list agent sent us a non server event...  Ignoring it." );
	    return;
	}
	CellEvent se = (CellEvent)event;
	if( ( se.eventCode() & ( CellEvent.SERVERBORN | CellEvent.SERVERGOINGDOWN | CellEvent.SERVERWITHDRAWN ) ) != 0 ) {
	    if( se instanceof CellBornCellEvent ) {
		CellAddress ca = ((CellBornCellEvent)se).getAddress();
		try {
		    ama.monitorCell( this, ca );
		} catch( RemoteException error ) {
		    Debug.error( "Remote exception while trying to ask the agent monitoring agent to monitor " + ca );
		} catch( UnableToMonitorCellException error ) {
		    Debug.error( "Agent monitoring agent is unable to monitor " + ca );
		}
	    } else if( ( se instanceof CellGoingDownCellEvent ) || 
		       ( se instanceof CellWithdrawnCellEvent ) ) {
		CellAddress ca = null;
		if( se instanceof CellGoingDownCellEvent ) 
		    ca = ((CellGoingDownCellEvent)se).getAddress();
		else
		    ca = ((CellWithdrawnCellEvent)se).getAddress();
		try {
		    ama.stopMonitoringCell( this, ca );
		} catch( RemoteException error ) {
		    Debug.error( "Remote exception while trying to ask the agent monitoring agent to stop monitoring " + ca );
		}
	    }
	}
}