cvs commit: xml-axis/java/samples/bidbuy RegistryService.java

[du...@apache.org]

dug         01/05/09 17:46:53

  Added:       java/samples/bidbuy RegistryService.java
  Log:
  Need a registry
  
  Revision  Changes    Path
  1.1                  xml-axis/java/samples/bidbuy/RegistryService.java
  
  Index: RegistryService.java
  ===================================================================
  package samples.bidbuy ;
  
  import java.util.Enumeration;
  import java.util.Hashtable;
  import java.util.Vector;
  import java.io.FileInputStream ;
  import java.io.FileOutputStream ;
  import java.io.ObjectInputStream ;
  import java.io.ObjectOutputStream ;
  
  public class RegistryService {
  
      private static Hashtable registry = new Hashtable();
  
      /**
        * Find a named service in a list
        * @param list of services
        * @param name to search for
        * @return service found (or null)
        */
    
      public RegistryService() {
        load();
      }
  
      public void load() {
        try {
          FileInputStream fis = new FileInputStream("bid.reg");
          ObjectInputStream ois = new ObjectInputStream( fis );
          registry = (Hashtable) ois.readObject();
          ois.close();
          fis.close();
        } catch(java.io.FileNotFoundException fnfe){
          // nop
        } catch(Exception e){
          e.printStackTrace();
        }
      }
  
      public void save() {
        try {
          FileOutputStream fos = new FileOutputStream("bid.reg");
          ObjectOutputStream oos = new ObjectOutputStream( fos );
          oos.writeObject( registry );
          oos.close();
          fos.close();
        } catch(Exception e){
          e.printStackTrace();
        }
      }
  
      private Service find(Vector list, String name) {
          Enumeration e = list.elements();
          while (e.hasMoreElements()) {
              Service s = (Service) e.nextElement();
              if (s.getServiceName().equals(name)) return s;
          }
          return null;
      }
  
      /**
       * Register a new serivce
       * @param server name
       * @param url of endpoint
       * @param stype
       * @param wsdl
       */
      public void Register(String name, String url, String stype, String wsdl) {
          Vector list = (Vector)registry.get(stype);
          if (list == null) registry.put(stype, list=new Vector());
          Service service = find(list, name);
          if (service==null)
              list.add(service=new Service());
          service.setServiceName(name);
          service.setServiceUrl(url);
          service.setServiceType(stype);
          service.setServiceWsdl(wsdl);
          save();
      }
  
      /**
       * Return the current list of services as an array
       * @param Service Name
       * @return List of servers that implement that service
       */
      public Service[] Lookup(String stype) {
          if (!registry.containsKey(stype)) return new Service[] {};
          Vector list = (Vector)registry.get(stype);
          Service[] result = new Service[list.size()];
          list.copyInto(result);
          return result;
      }
  
      /*
       * Return the current list of services as a string
       */
      public String LookupAsString(String stype) {
          Service[] services = Lookup(stype);
          String result = "";
          for (int i=0; i<services.length; i++) {
              Service service = services[i];
              result += service.getServiceName() + "\t" + 
                        service.getServiceUrl() + "\t" +
                        service.getServiceType() + "\t" + 
                        service.getServiceWsdl() + "\n";
          }
          return result;
      }
  
  }