saveincomingmessagetask.java

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

package com.infobank.superchannel.daemon.messagelauncher;

import java.rmi.RemoteException;
import java.util.Queue;

import org.apache.commons.configuration.Configuration;

import com.infobank.superchannel.daemon.databasecache.DatabaseCache;
import com.infobank.superchannel.pojo.TextMessage;
import com.infobank.superchannel.util.DaemonConfiguration;

/**
 * @author Xiaoguang Sun
 * @version 类说明: Save incoming message task
 */
public class SaveIncomingMessageTask implements Runnable {
  // 消息发送服务器对象
  private MessageLauncherDaemon daemon=null;
  
  // 连续两次状态更新间的等待时间
  private int interval=0;

    private String tag=null;
  
  /**
   * 构造函数
   * @param daemon 消息发送服务器对象
   */
  public SaveIncomingMessageTask(MessageLauncherDaemon daemon){
    this.daemon=daemon;
        tag=daemon.getTag();

        StringBuilder sb=new StringBuilder();
        sb.append("/daemon[@type='MessageLauncher' and @tag='");
        sb.append(tag);
        sb.append("']/task/updater/incoming/interval");
    DaemonConfiguration config=DaemonConfiguration.getInstance();
    interval=config.getInt(sb.toString());
  }

  /**
   * 更新消息状态任务执行体
   */
  public void run(){
    while(daemon.isRunnable()){
      try{
        daemon.saveIncomingMessage();
        Thread.sleep(interval);
      }catch(InterruptedException ex){
        ex.printStackTrace();
      }
    }
  }
}