agentadmin.java

一个类似于openJMS分布在ObjectWeb之下的JMS消息中间件。

      logmon.log(BasicLevel.DEBUG,
                 "AgentAdmin.doReact(" + cmd + ")");
    
    A3CMLServer server = null;
    try {
      server = a3cmlConfig.getServer(cmd.serverName);
    } catch(fr.dyade.aaa.agent.conf.UnknownServerException e) { return;}
    if (server == null) return;
    
    try {
      if (server.sid == AgentServer.getServerId()) {
        if (logmon.isLoggable(BasicLevel.DEBUG))
          logmon.log(BasicLevel.DEBUG,
                     "stopScript.add( StopNetworkCmd(" + 
                     cmd.serverName + "))");
        stopScript.add(new StopNetworkCmd(server.sid,
                                          cmd.domain));
      }
      removeNetwork(server.sid,cmd.domain);
    } catch (Exception exc) {
      if (logmon.isLoggable(BasicLevel.ERROR))
        logmon.log(BasicLevel.ERROR, "", exc);
      throw new NetworkCmdException(exc);
    }
  }

  /** 
   * remove server
   *
   * @param cmd RemoveServerCmd
   *
   * @exception ServerCmdException
   */
  private void doReact(RemoveServerCmd cmd) throws ServerCmdException {
    if (logmon.isLoggable(BasicLevel.DEBUG))
      logmon.log(BasicLevel.DEBUG,
                 "AgentAdmin.doReact(" + cmd + ")");
    
    A3CMLServer svr = null;
    try {
      svr = a3cmlConfig.getServer(cmd.name);
    } catch (fr.dyade.aaa.agent.conf.UnknownServerException exc) {
      return;
    }
    if (svr == null) return;

    try {
      removeServer(svr.sid);
    } catch (Exception exc) {
      if (logmon.isLoggable(BasicLevel.ERROR))
        logmon.log(BasicLevel.ERROR, "", exc);
      throw new ServerCmdException(exc);
    }
  }

  /** 
   * remove service
   *
   * @param cmd RemoveServiceCmd
   *
   * @exception ServiceCmdException
   */
  private void doReact(RemoveServiceCmd cmd) throws ServiceCmdException {
    if (logmon.isLoggable(BasicLevel.DEBUG))
      logmon.log(BasicLevel.DEBUG,
                 "AgentAdmin.doReact(" + cmd + ")");
    
    A3CMLServer server = null;
    try {
      server = a3cmlConfig.getServer(cmd.serverName);
    } catch(fr.dyade.aaa.agent.conf.UnknownServerException exc) { return;}

    if (server == null) return;
    try {
      if (server.sid == AgentServer.getServerId()) {
        if (logmon.isLoggable(BasicLevel.DEBUG))
          logmon.log(BasicLevel.DEBUG,
                     "stopScript.add( StopServiceCmd(" + 
                     cmd.className + "))");
        stopScript.add(new StopServiceCmd(cmd.className,
                                          cmd.args));
      }
      removeService(server.sid,cmd.className);
    } catch (Exception exc) {
      if (logmon.isLoggable(BasicLevel.ERROR))
        logmon.log(BasicLevel.ERROR, "", exc);
      throw new ServiceCmdException(exc);
    }
  }

  /** 
   * unset server property
   *
   * @param cmd UnsetServerPropertyCmd
   *
   * @exception PropertyCmdException
   */
  private void doReact(UnsetServerPropertyCmd cmd) throws PropertyCmdException {
    if (logmon.isLoggable(BasicLevel.DEBUG))
      logmon.log(BasicLevel.DEBUG,
                 "AgentAdmin.doReact(" + cmd + ")");
    
    A3CMLServer server = null;
    try {
      server = a3cmlConfig.getServer(cmd.serverName);
    } catch(fr.dyade.aaa.agent.conf.UnknownServerException exc) { return;}
    
    if (server == null) return;
    try {
      unsetServerProperty(server.sid,cmd.name);
    } catch (Exception exc) {
      if (logmon.isLoggable(BasicLevel.ERROR))
        logmon.log(BasicLevel.ERROR, "", exc);
      throw new PropertyCmdException(exc);
    }
  }

  /** 
   * unset property
   *
   * @param cmd UnsetPropertyCmd
   *
   * @exception PropertyCmdException
   */
  private void doReact(UnsetPropertyCmd cmd) throws PropertyCmdException {
    if (logmon.isLoggable(BasicLevel.DEBUG))
      logmon.log(BasicLevel.DEBUG,
                 "AgentAdmin.doReact(" + cmd + ")");
    
    try {
      unsetProperty(cmd.name);
    } catch (Exception exc) {
      if (logmon.isLoggable(BasicLevel.ERROR))
        logmon.log(BasicLevel.ERROR, "", exc);
      throw new PropertyCmdException(exc);
    }
  }

  /** 
   * unset network address translation
   *
   * @param cmd UnsetServerNatCmd
   *
   * @exception NatCmdException
   */
  private void doReact(UnsetServerNatCmd cmd) throws NatCmdException {
    if (logmon.isLoggable(BasicLevel.DEBUG))
      logmon.log(BasicLevel.DEBUG,
                 "AgentAdmin.doReact(" + cmd + ")");

    try {
      A3CMLServer server = a3cmlConfig.getServer(cmd.serverName);
      short sid = a3cmlConfig.getServerIdByName(cmd.translationServerName);
      server.removeNat(sid);
    } catch (Exception exc) {
      if (logmon.isLoggable(BasicLevel.ERROR))
        logmon.log(BasicLevel.ERROR, "", exc);
      throw new NatCmdException(exc);
    }
  }
  /** 
   * unset jvm args
   *
   * @param cmd UnsetJvmArgsCmd
   *
   * @exception JvmArgsCmdException
   */
  private void doReact(UnsetJvmArgsCmd cmd) throws JvmArgsCmdException {
    if (logmon.isLoggable(BasicLevel.DEBUG))
      logmon.log(BasicLevel.DEBUG,
                 "AgentAdmin.doReact(" + cmd + ")");
    
    A3CMLServer server = null;
    try {
      server = a3cmlConfig.getServer(cmd.serverName);
    } catch(fr.dyade.aaa.agent.conf.UnknownServerException exc) { return;}
    
    if (server == null) return;
    try {
      unsetJvmArgs(server.sid,cmd.args);
    } catch (Exception exc) {
      if (logmon.isLoggable(BasicLevel.ERROR))
        logmon.log(BasicLevel.ERROR, "", exc);
      throw new JvmArgsCmdException(exc);
    }
  }

  private void removeDomain(String domainName) throws Exception {
    if (logmon.isLoggable(BasicLevel.DEBUG))
      logmon.log(BasicLevel.DEBUG,
                 "AgentAdmin.removeDomain(" + domainName + ")");
    
    a3cmlConfig.removeDomain(domainName);
  }

  private void removeNetwork(short sid, String domainName) throws Exception {
    if (logmon.isLoggable(BasicLevel.DEBUG))
      logmon.log(BasicLevel.DEBUG,
                 "AgentAdmin.removeNetwork(" + sid + 
                 "," + domainName + ")");
    try {
      A3CMLServer server = a3cmlConfig.getServer(sid);
      if (server == null) return;
      for (int i = 0; i < server.networks.size(); i++) {
        A3CMLNetwork network = 
          (A3CMLNetwork)server.networks.elementAt(i);
        if (network.domain.equals(domainName)) {
          if (logmon.isLoggable(BasicLevel.DEBUG))
            logmon.log(BasicLevel.DEBUG,
                       "AgentAdmin.removeNetwork remove : " + network);
          server.networks.removeElementAt(i);
        }
      }
    } catch (fr.dyade.aaa.agent.conf.UnknownServerException exc) {
      if (logmon.isLoggable(BasicLevel.ERROR))
        logmon.log(BasicLevel.ERROR, "", exc);
      return;
    }
  }

  private void removeServer(short sid) throws Exception {
    if (logmon.isLoggable(BasicLevel.DEBUG))
      logmon.log(BasicLevel.DEBUG,
                 "AgentAdmin.removeServer(" + sid + ")");

    try {
      ServerDesc servDesc = AgentServer.getServerDesc(sid);
      if (servDesc.domain instanceof Network)
        ((Network) servDesc.domain).delServer(sid);
    } catch (Exception exc) {
      if (logmon.isLoggable(BasicLevel.DEBUG))
        logmon.log(BasicLevel.DEBUG,
                   "AgentAdmin.removeServer remove server #" + sid, exc);
      return;
    }

    try {
      // remove server in serverDesc
      AgentServer.removeServerDesc(sid);
      for (Enumeration e = AgentServer.elementsServerDesc(); e.hasMoreElements(); ) {
        ServerDesc sd = (ServerDesc)e.nextElement();
        if (sd.gateway == sid) {
          sd.gateway = -1;
          sd.domain = null;
        }
      }
    } catch (Exception exc) {
      if (logmon.isLoggable(BasicLevel.DEBUG))
        logmon.log(BasicLevel.DEBUG,
                   "AgentAdmin.removeServer remove server #" + sid, exc);
    }

    // remove server in a3cmlConfig
    a3cmlConfig.removeServer(sid);
    for (Enumeration d = a3cmlConfig.domains.elements(); d.hasMoreElements(); ) {
      A3CMLDomain domain = (A3CMLDomain)d.nextElement();
      for (int i = 0; i < domain.servers.size(); i++) {
        A3CMLServer server = (A3CMLServer) domain.servers.elementAt(i);
        if (server.sid == sid) {
          domain.servers.removeElementAt(i);
          if (logmon.isLoggable(BasicLevel.DEBUG))
            logmon.log(BasicLevel.DEBUG,
                       "AgentAdmin.removeServer remove server #" + sid +
                       " in domain " + domain);
        }
      }
    }
  }

  private void removeService(short sid, String className) throws Exception {
    if (logmon.isLoggable(BasicLevel.DEBUG))
      logmon.log(BasicLevel.DEBUG,
                 "AgentAdmin.removeService(" + sid +
                 "," + className + ")");

    A3CMLServer server = a3cmlConfig.getServer(sid);
    if (server == null) return;
    for (int i = 0; i < server.services.size(); i++) {
      A3CMLService service = 
        (A3CMLService) server.services.elementAt(i);
      if (service.classname.equals(className)) {
        server.services.removeElementAt(i);
        if (logmon.isLoggable(BasicLevel.DEBUG))
          logmon.log(BasicLevel.DEBUG,
                     "AgentAdmin.removeService service = " + service);
      }
    }
  }

  private void unsetServerProperty(short sid, String name) throws Exception {
    if (logmon.isLoggable(BasicLevel.DEBUG))
      logmon.log(BasicLevel.DEBUG,
                 "AgentAdmin.unsetServerProperty(" + sid +
                 "," + name + ")");
    
    A3CMLServer server = a3cmlConfig.getServer(sid);
    if (server == null) return;
    server.removeProperty(name);
  }

  private void unsetProperty(String name) throws Exception {
    if (logmon.isLoggable(BasicLevel.DEBUG))
      logmon.log(BasicLevel.DEBUG,
                 "AgentAdmin.unsetProperty(" + name + ")");

    a3cmlConfig.removeProperty(name);
  }

  private void unsetJvmArgs(short sid, String args) throws Exception {
    if (logmon.isLoggable(BasicLevel.DEBUG))
      logmon.log(BasicLevel.DEBUG,
                 "AgentAdmin.unsetArgs(" + sid +
                 "," + name + ")");

    A3CMLServer server = a3cmlConfig.getServer(sid);
    if (server == null) return;
    //server.jvmArgs = server.jvmArgs.replaceAll(args,"");

     StringTokenizer st = new StringTokenizer(args);
     while (st.hasMoreTokens()) {
       String toRemove = st.nextToken();
       int i = server.jvmArgs.indexOf(toRemove);
       if (i > -1) {
         String begin = server.jvmArgs.substring(0,i);
         String end = server.jvmArgs.substring(i + toRemove.length());
         server.jvmArgs = begin.concat(end);
       }
     }

    if (server.jvmArgs == "")
      server.jvmArgs = null;
    if (logmon.isLoggable(BasicLevel.DEBUG))
      logmon.log(BasicLevel.DEBUG,
                 "AgentAdmin.unsetArgs jvmArgs = " + server.jvmArgs);
  }

  public Short getSid() {
    if (maxId > -1) {
      maxId += 1;
      return new Short(maxId);
    } else {
      return null;
    }
  }

//   private boolean setGatewayAndDomain(A3CMLPServer server,
//                                       A3CMLPServer current) throws Exception {
//     if (logmon.isLoggable(BasicLevel.DEBUG))
//       logmon.log(BasicLevel.DEBUG,
//                  "AgentAdmin.setGatewayAndDomain(" + server + "," + current + ")");
        
//     ServerDesc desc = AgentServer.getServerDesc(server.sid);
//     logmon.log(BasicLevel.DEBUG,
//                  "AgentAdmin.setGatewayAndDomain:" + desc);

//     // Get routing infos from config
//     if (server.domain != null) {
//       if (server.gateway != -1)
//         desc.gateway = server.gateway;
//       else
//         desc.gateway = server.sid;
// //       desc.domain = a3cmlConfig.getDomain(server.domain).consumer;
//       desc.domain = AgentServer.getConsumer(server.domain);
//       logmon.log(BasicLevel.DEBUG, "AgentAdmin.setGatewayAndDomain:" + desc);
    
//       return true;
//     }

//     return false;
//   }
}