databasecachestatusmonitorclient.java

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

package com.infobank.superchannel.test;

import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
import java.util.List;

import com.infobank.superchannel.admin.monitor.DatabaseCacheStatusMonitor;
import com.infobank.superchannel.pojo.BlackListLog;
import com.infobank.superchannel.pojo.TextMessageLog;

public class DatabaseCacheStatusMonitorClient {
  /*
  private static void printLog(List<TextMessageLog> log, String name){
    System.err.println("There are " + log.size() + " " + name);
    for(int idx=0;idx<log.size();++idx){
      TextMessageLog logitem=log.get(idx);
      System.err.println(logitem.timestamp+" : "+logitem.message.getMessage());
    }
  }
  
  private static void printInt(int val,String name){
    System.err.println(name + " is " + val);
  }

  public static void main(String[] args) {
    String host=(args.length<1)?null:args[0];
    try{
      Registry registry=LocateRegistry.getRegistry(host);
      DatabaseCacheStatusMonitor stub=(DatabaseCacheStatusMonitor) registry.lookup("DatabaseCacheStatusMonitor");

      printLog(stub.getBlockMessageLog(),"Blocked Message Logs");
      printLog(stub.getNewMessageLog(),"New Message Logs");
      printLog(stub.getUpdateMessageLog(),"Update Message Logs");
      printLog(stub.getNewMessageStatusLog(),"New Message Status Logs");

      BlackListLog log=stub.getBlackListLog();
      List<String> bl=log.blacklist.list;
      System.err.println("There are "+ bl.size() + " entries in blacklist");
      for(int idx=0;idx<bl.size();++idx){
        System.err.println(bl.get(idx));
      }
      System.err.println("Blacklist Updated at "+log.timestamp);
      
      printInt(stub.getMessageQueueSize(),"Message Queue Size");
      printInt(stub.getNumberOfFailedMessages(),"Number of Failed Messages");
      printInt(stub.getNumberOfSuccessfulMessages(),"Number of Successful Messages");
      printInt(stub.getStatusQueueSize(),"Status Queue Size");
    }
    catch(Exception e){
      System.err.println("Client Exception: "+e.toString());
      e.printStackTrace();
    }
  }*/
}