Source code: com/arranger/jarl/test/LocrianTest.java

   package com.arranger.jarl.test;
   
   import com.arranger.agent.IAgent;
   import com.arranger.agent.IAgentRegistry;
   import junit.framework.TestCase;
   
   import java.io.IOException;
   import java.io.Serializable;
   import java.net.Socket;
  import java.rmi.registry.LocateRegistry;
  import java.rmi.registry.Registry;
  import java.rmi.server.RMIClientSocketFactory;
  import java.rmi.server.RemoteServer;
  import java.rmi.Naming;
  import java.util.Collection;
  import java.util.Iterator;
  
  /**
   * LocrianTest created on Mar 9, 2003
   */
  public class LocrianTest extends TestCase {
  
      protected String m_serverName = "locrian";
      protected String m_serverPort = "2112";
      protected String m_registryName = "jarl";
  
  
      public void testLocrian() throws Exception {
          RemoteServer.setLog(System.out);
  
          Registry registry = LocateRegistry.getRegistry("192.168.27.127", Integer.parseInt(m_serverPort), new MYCSF());
          String[] names = registry.list();
          for (int index = 0; index < names.length; index++) {
              System.out.println(names[index]);
          }
          //IAgentRegistry agentRegistry = (IAgentRegistry)registry.lookup(m_registryName);
          IAgentRegistry agentRegistry = (IAgentRegistry)Naming.lookup("rmi://" + "192.168.27.127" + ":" + Integer.parseInt(m_serverPort) + "/" + m_registryName);
          System.out.println(agentRegistry.toString());
          Collection collection = agentRegistry.getAgents();
          for (Iterator it = collection.iterator(); it.hasNext();) {
              IAgent agent = (IAgent)it.next();
              System.out.println(agent.getHostName());
          }
      }
  
      public static class MYCSF implements RMIClientSocketFactory, Serializable {
  
          public Socket createSocket(String host, int port)
              throws IOException {
  
              return new Socket(host, port);
          }
      }
  }