channelstatusmonitorclient.java.svn-base

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

package com.infobank.superchannel.test;

import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
import java.rmi.server.UnicastRemoteObject;
import java.util.LinkedList;
import java.util.List;

import com.infobank.superchannel.admin.monitor.ChannelStatusMonitor;
import com.infobank.superchannel.admin.monitor.DatabaseCacheStatusMonitor;
import com.infobank.superchannel.admin.monitor.MessageLauncherStatusMonitor;
import com.infobank.superchannel.admin.monitor.implementation.DatabaseCacheStatusMonitorImpl;
import com.infobank.superchannel.observer.implementation.MemoryPersistenceDatabaseCacheStatusObserver;
import com.infobank.superchannel.pojo.BlackList;
import com.infobank.superchannel.pojo.MessageBucketLog;
import com.infobank.superchannel.pojo.TextMessage;
import com.infobank.superchannel.pojo.TextMessageLog;

public class ChannelStatusMonitorClient {
  /*
  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 printBucketLog(List<MessageBucketLog> log, String name){
    System.err.println("There are " + log.size() + " " + name);
    for(int idx=0;idx<log.size();++idx){
      MessageBucketLog logitem=log.get(idx);
      System.err.println(logitem.timestamp+" : "+logitem.content);
    }
  }

  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);
      ChannelStatusMonitor stub=(ChannelStatusMonitor) registry.lookup("ChannelStatusMonitor");
      
      printLog(stub.getDeliverMessageLog(),"Deliver Message Logs");     
      printInt(stub.getAverageTimeUsagePerMessage(),"Average time usage per message (sec.)");
      printInt(stub.getNumberOfSentMessages(),"Number of sent message");
    }
    catch(Exception e){
      System.err.println("Client Exception: "+e.toString());
      e.printStackTrace();
    }
  }*/
}