messagelauncherstatusmonitorserver.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.MessageLauncherStatusMonitor;
import com.infobank.superchannel.admin.monitor.implementation.DatabaseCacheStatusMonitorImpl;
import com.infobank.superchannel.admin.monitor.implementation.MessageLauncherStatusMonitorImpl;
import com.infobank.superchannel.observer.MessageLauncherStatusObserver;
import com.infobank.superchannel.observer.implementation.MemoryPersistenceDatabaseCacheStatusObserver;
import com.infobank.superchannel.observer.implementation.MemoryPersistenceMessageLauncherStatusObserver;
import com.infobank.superchannel.pojo.BlackList;
import com.infobank.superchannel.pojo.TextMessage;

public class MessageLauncherStatusMonitorServer {
  /**
   * @param args
   */
  /*
  public static void main(String[] args) {
    try{
      RemoteMessageLauncherStatusObserver observer=new RemoteMessageLauncherStatusObserver();
      for(int idx=0;idx<10;++idx){
        observer.changeMessageStatus(new TextMessage("Blocked Message "+idx));
        Thread.sleep(100);
      }

      for(int idx=0;idx<20;++idx){
        //MessageBucket bucket=new MessageBucket(new TextMessage("New Mass Message Bucket " + idx));
        //observer.newMassMessageBucket(bucket);
        Thread.sleep(100);
      }
      observer.massMessageQueueSize(20);
      
      for(int idx=0;idx<30;++idx){
        //MessageBucket bucket=new MessageBucket(new TextMessage("New General Message Bucket " + idx));
        //observer.newGeneralMessageBucket(bucket);
        Thread.sleep(100);
      }
      observer.generalMessageQueueSize(30);
      
      MessageLauncherStatusMonitorImpl mlmon = new MessageLauncherStatusMonitorImpl(observer);
      mlmon.attach();

      MessageLauncherStatusMonitor stub = (MessageLauncherStatusMonitor) UnicastRemoteObject.exportObject(mlmon, 0);

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

        System.err.println("Server is ready");
        
        Thread.sleep(10000);
        
        System.err.println("Server is preparing to shutdown");
        
        while(!UnicastRemoteObject.unexportObject(mlmon, false)){
          Thread.sleep(1000);
        }
    } catch (Exception e) {
        System.err.println("Server exception: " + e.toString());
        e.printStackTrace();
    }
  }
  */
}