updatestatustask.java

来自「监控整个SP系统的SMS信息通道的发送情况并且生成日志。 支持权限判断。」· Java 代码 · 共 55 行

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 类说明: 短信息状态更新任务
 */
public class UpdateStatusTask implements Runnable {
  // 消息发送服务器对象
  private MessageLauncherDaemon daemon=null;
  
  // 连续两次状态更新间的等待时间
  private int interval=0;

  private String tag;
  
  /**
   * 构造函数
   * @param daemon 消息发送服务器对象
   */
  public UpdateStatusTask(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/status/interval");
  DaemonConfiguration config=DaemonConfiguration.getInstance();
  interval=config.getInt(sb.toString());
  }

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