databasecachestatusmonitorserver.java

监控整个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.DatabaseCacheStatusMonitor;
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.TextMessage;

public class DatabaseCacheStatusMonitorServer {
  /**
   * @param args
   */
  /*
  public static void main(String[] args) {
    try{
      RemoteDatabaseCacheStatusObserver observer=new RemoteDatabaseCacheStatusObserver();
      for(int idx=0;idx<10;++idx){
        observer.blockMessage(new TextMessage("Blocked Message "+idx));
        Thread.sleep(100);
      }
      for(int idx=0;idx<20;++idx){
        observer.newMessage(new TextMessage("New Message "+idx));
        Thread.sleep(100);
      }
      for(int idx=0;idx<30;++idx){
        observer.updateMessageStatus(new TextMessage("Update Message "+idx));
        Thread.sleep(10);
      }
      for(int idx=0;idx<40;++idx){
        observer.newMessageStatus(new TextMessage("New Message Status "+idx));
        Thread.sleep(10);
      }
      List<String> blacklist=new LinkedList<String>();
      for(int idx=0;idx<50;++idx){
        blacklist.add("black "+idx);
      }
      
      observer.reloadBlackList(new BlackList(blacklist));
      observer.messageQueueSize(60);
      observer.statusQueueSize(70);
      observer.numberOfFailedMessages(80);
      observer.numberOfSuccessfulMessages(90);
      observer.messageQueueSize(100);

      DatabaseCacheStatusMonitorImpl dbmon = new DatabaseCacheStatusMonitorImpl(observer);
      dbmon.attach();

      DatabaseCacheStatusMonitor stub = (DatabaseCacheStatusMonitor) UnicastRemoteObject.exportObject(dbmon, 0);

        // Bind the remote object's stub in the registry
        Registry registry = LocateRegistry.getRegistry();
        registry.rebind("DatabaseCacheStatusMonitor", stub);

        System.err.println("Server is ready");
        
        Thread.sleep(10000);
        
        System.err.println("Server is preparing to shutdown");
        
        while(!UnicastRemoteObject.unexportObject(dbmon, false)){
          Thread.sleep(1000);
        }

    } catch (Exception e) {
        System.err.println("Server exception: " + e.toString());
        e.printStackTrace();
    }
  }
*/
}