configurationtest.java.svn-base

监控整个SP系统的SMS信息通道的发送情况并且生成日志。 支持权限判断。

package com.infobank.superchannel.test;

import org.apache.commons.configuration.*;
import org.apache.commons.configuration.tree.xpath.XPathExpressionEngine;

public class ConfigurationTest{
  private static CombinedConfiguration config=null;

  private static String printString(String path){
    String result=config.getString(path);
    System.err.println(path+"="+result);
    return result;
  }

  public static void main(String[] argv){

    try{
      DefaultConfigurationBuilder dfb=new DefaultConfigurationBuilder("conf/SuperChannelConfig.xml");

      config=dfb.getConfiguration(true);

      config.setExpressionEngine(new XPathExpressionEngine());

      printString("/daemon[@type='SuperChannel']/security/token/timeout");

      printString("/daemon[@type='SuperChannel']/security/evictor/interval");

      printString("/daemon[@type='SuperChannel']/endpoint/@name");

      int numberOfItems=config.getMaxIndex("/daemon/datasource")+1;
      System.err.println("max index of /daemon/datasource="+numberOfItems);

      for(int idx=1;idx<=numberOfItems;++idx){
        printString("/daemon/datasource["+idx+"]/@name");
        printString("/daemon/datasource["+idx+"]/url");
        printString("/daemon/datasource["+idx+"]/user");
        printString("/daemon/datasource["+idx+"]/password");
        printString("/daemon/datasource["+idx+"]/driver");
        printString("/daemon/datasource["+idx+"]/initialSize");
        printString("/daemon/datasource["+idx+"]/maxIdle");
        printString("/daemon/datasource["+idx+"]/minIdle");
        printString("/daemon/datasource["+idx+"]/maxActive");
        printString("/daemon/datasource["+idx+"]/logAbandoned");
        printString("/daemon/datasource["+idx+"]/removeAbandoned");
        printString("/daemon/datasource["+idx+"]/removeAbandonedTimeout");
        printString("/daemon/datasource["+idx+"]/maxWait");
      }

      numberOfItems=config.getMaxIndex("/daemon[@type='DatabaseCache']/observer[@type='LogObserver']/alerts/alert")+1;

      for(int idx=1;idx<=numberOfItems;++idx){
        printString("/daemon[@type='DatabaseCache']/observer[@type='LogObserver']/alerts/alert["+idx+"]/@level");
        printString("/daemon[@type='DatabaseCache']/observer[@type='LogObserver']/alerts/alert["+idx+"]/@type");
        printString("/daemon[@type='DatabaseCache']/observer[@type='LogObserver']/alerts/alert["+idx+"]");
      }

      printString("/daemon[@type='DatabaseCache']/observer[@type='DatabaseCacheStatusObserver']/capacity/@persistence");
      printString("/daemon[@type='DatabaseCache']/observer[@type='DatabaseCacheStatusObserver']/capacity[@persistence='memory']/blockMessage");
      printString("/daemon[@type='DatabaseCache']/observer[@type='DatabaseCacheStatusObserver']/capacity[@persistence='memory']/newMessage");
      printString("/daemon[@type='DatabaseCache']/observer[@type='DatabaseCacheStatusObserver']/capacity[@persistence='memory']/updateMessage");
      printString("/daemon[@type='DatabaseCache']/observer[@type='DatabaseCacheStatusObserver']/capacity[@persistence='memory']/newMessageStatus");
      printString("/daemon[@type='DatabaseCache']/observer[@type='DatabaseCacheStatusObserver']/capacity[@persistence='memory']/blackList");

      numberOfItems=config.getMaxIndex("/daemon[@type='MessageLauncher' and @tag='021']/observer[@type='LogObserver']/alerts/alert")+1;

      for(int idx=1;idx<=numberOfItems;++idx){
        printString("/daemon[@type='MessageLauncher' and @tag='021']/observer[@type='LogObserver']/alerts/alert["+idx+"]/@level");
        printString("/daemon[@type='MessageLauncher' and @tag='021']/observer[@type='LogObserver']/alerts/alert["+idx+"]/@type");
        printString("/daemon[@type='MessageLauncher' and @tag='021']/observer[@type='LogObserver']/alerts/alert["+idx+"]");
      }

      printString("/daemon[@type='MessageLauncher' and @tag='021']/observer[@type='MessageLauncherObserver']/capacity/@persistence");
      printString("/daemon[@type='MessageLauncher' and @tag='021']/observer[@type='MessageLauncherObserver']/capacity[@persistence='memory']/changeMessageStatus");
      printString("/daemon[@type='MessageLauncher' and @tag='021']/observer[@type='MessageLauncherObserver']/capacity[@persistence='memory']/massMessageBucket");
      printString("/daemon[@type='MessageLauncher' and @tag='021']/observer[@type='MessageLauncherObserver']/capacity[@persistence='memory']/generalMessageBucket");

      printString("/daemon[@type='MessageLauncher' and @tag='021']/observer[@type='ChannelStatusObserver']/capacity/@persistence");
      printString("/daemon[@type='MessageLauncher' and @tag='021']/observer[@type='ChannelStatusObserver']/capacity[@persistence='memory']/deliverMessage");

      printString("/daemon[@type='DatabaseCache']/message/maxRetry");
      printString("/daemon[@type='DatabaseCache']/message/queue/capacity");

      numberOfItems=config.getMaxIndex("/daemon[@type='DatabaseCache']/task/reader/tables/table")+1;
      for(int idx=1;idx<=numberOfItems;++idx){
        String result=null;
        printString("/daemon[@type='DatabaseCache']/task/reader/tables/table["+idx+"]/name");
        result=printString("/daemon[@type='DatabaseCache']/task/reader/tables/table["+idx+"]/@datasource");
        if(result==null){
          printString("/daemon/datasource[@name='default']/url");
        }else{
          printString("/daemon/datasource[@name='"+result+"']/url");
        }

        result=printString("/daemon[@type='DatabaseCache']/task/reader/tables/table["+idx+"]/@status");
        if(result==null){
          printString("/daemon[@type='DatabaseCache']/message/status[@name='default']/delivered");
          printString("/daemon[@type='DatabaseCache']/message/status[@name='default']/sending");
          printString("/daemon[@type='DatabaseCache']/message/status[@name='default']/blocked");
          printString("/daemon[@type='DatabaseCache']/message/status[@name='default']/waiting");
        }else{
          printString("/daemon[@type='DatabaseCache']/message/status[@name='"+result+"']/delivered");
          printString("/daemon[@type='DatabaseCache']/message/status[@name='"+result+"']/sending");
          printString("/daemon[@type='DatabaseCache']/message/status[@name='"+result+"']/blocked");
          printString("/daemon[@type='DatabaseCache']/message/status[@name='"+result+"']/waiting");
        }

        result=printString("/daemon[@type='DatabaseCache']/task/reader/tables/table["+idx+"]/@result");
        if(result==null){
          printString("/daemon[@type='DatabaseCache']/message/result[@name='default']/successful");
          printString("/daemon[@type='DatabaseCache']/message/result[@name='default']/failed");
          printString("/daemon[@type='DatabaseCache']/message/result[@name='default']/overflow");
        }else{
          printString("/daemon[@type='DatabaseCache']/message/result[@name='"+result+"']/successful");
          printString("/daemon[@type='DatabaseCache']/message/result[@name='"+result+"']/failed");
          printString("/daemon[@type='DatabaseCache']/message/result[@name='"+result+"']/overflow");
        }

        result=printString("/daemon[@type='DatabaseCache']/task/reader/tables/table["+idx+"]/@callback");
        if(result==null){
          printString("/daemon[@type='DatabaseCache']/message/callback[@name='default']/pattern");
        }
        else{
          printString("/daemon[@type='DatabaseCache']/message/callback[@name='"+result+"']/pattern");
        }

        printString("/daemon[@type='DatabaseCache']/task/reader/tables/table["+idx+"]/name");
        printString("/daemon[@type='DatabaseCache']/task/reader/tables/table["+idx+"]/maxRecordNumber");
        printString("/daemon[@type='DatabaseCache']/task/reader/tables/table["+idx+"]/interval");
        printString("/daemon[@type='DatabaseCache']/task/reader/tables/table["+idx+"]/tag");
      }

      printString("/daemon[@type='DatabaseCache']/jvm/@home");
      printString("/daemon[@type='DatabaseCache']/jvm/main");
      printString("/daemon[@type='DatabaseCache']/jvm/classpath");
      printString("/daemon[@type='DatabaseCache']/jvm/arguments[@type='JVM']");
      printString("/daemon[@type='DatabaseCache']/jvm/arguments[@type='Application']");
      numberOfItems=config.getMaxIndex("/daemon[@type='DatabaseCache']/jvm/arguments")+1;
      for(int idx=1;idx<=numberOfItems;++idx){
        printString("/daemon[@type='DatabaseCache']/jvm/arguments["+idx+"]/@type");
        printString("/daemon[@type='DatabaseCache']/jvm/arguments["+idx+"]");
      }

      numberOfItems=config.getMaxIndex("/daemon[@type='MessageLauncher']/jvm")+1;
      System.err.println("there are "+numberOfItems+" msl");
      for(int idx=1;idx<=numberOfItems;++idx){
        printString("/daemon[@type='MessageLauncher']["+idx+"]/@tag");
      }


      printString("/daemon[@type='MessageLauncher' and @tag='021']/message/queue[@type='Mass']/@threshold");
      printString("/daemon[@type='MessageLauncher' and @tag='021']/message/queue[@type='Mass']/capacity");
      printString("/daemon[@type='MessageLauncher' and @tag='021']/message/queue[@type='Mass']/quota");
      printString("/daemon[@type='MessageLauncher' and @tag='021']/message/queue[@type='General']/capacity");

      printString("/daemon[@type='MessageLauncher' and @tag='021']/task/fetcher/interval");
      printString("/daemon[@type='MessageLauncher' and @tag='021']/task/fetcher/tag");
      printString("/daemon[@type='MessageLauncher' and @tag='021']/task/updater/status/interval");
      printString("/daemon[@type='MessageLauncher' and @tag='021']/task/updater/incoming/interval");
      printString("/daemon[@type='MessageLauncher' and @tag='021']/task/executor/maxNumber");
      printString("/daemon[@type='MessageLauncher' and @tag='021']/task/executor/minNumber");
      printString("/daemon[@type='MessageLauncher' and @tag='021']/task/executor/keepAliveTime");

      printString("/daemon[@type='MessageLauncher' and @tag='021']/channel/plugin/class");

      printString("/daemon[@type='MessageLauncher' and @tag='021']/jvm/@home");
      printString("/daemon[@type='MessageLauncher' and @tag='021']/jvm/main");
      printString("/daemon[@type='MessageLauncher' and @tag='021']/jvm/classpath");
      printString("/daemon[@type='MessageLauncher' and @tag='021']/jvm/arguments[@type='JVM']");
      printString("/daemon[@type='MessageLauncher' and @tag='021']/jvm/arguments[@type='Application']");

      System.err.println("number of task="+(config.getMaxIndex("/daemon[@type='DatabaseCache']/task")+1));

      printString("/daemon[@type='MessageLauncher' and @tag='021']/task/fetcher/interval");

      printString("/daemon[@type='MessageLauncher']/observer[@type='LogObserver']/alerts/alert[@level='fatal']");

    }catch(Exception ex){
      ex.printStackTrace();
    }
  }
}