filepersistencemessagelauncherstatusobserver.java

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

package com.infobank.superchannel.observer.implementation;

import java.util.List;
import java.util.Queue;

import org.apache.log4j.Logger;

import com.infobank.superchannel.daemon.messagelauncher.MessageLauncherDaemon;
import com.infobank.superchannel.observer.ChannelStatusObserver;
import com.infobank.superchannel.observer.MessageLauncherStatusObserver;
import com.infobank.superchannel.pojo.GenericLog;
import com.infobank.superchannel.pojo.MessageBucketLog;
import com.infobank.superchannel.pojo.TextMessage;
import com.infobank.superchannel.pojo.TextMessageLog;

/**
 * @author Xiaoguang Sun
 * @version 类说明: FilePersistence状态观察者
 */
public class FilePersistenceMessageLauncherStatusObserver 
  extends FilePersistenceLogObserver 
  implements  MessageLauncherStatusObserver {
  private Logger logger=null;
  
  public FilePersistenceMessageLauncherStatusObserver(MessageLauncherDaemon daemon){
    super(daemon);
    logger=Logger.getLogger(daemon.getClass());
  }
  /**
   *  消息状态变更
   * @param message 状态变更的消息
   */
  public void changeMessageStatus(TextMessage message) {
    StringBuffer sb=new StringBuffer("Changing message status to ");
    sb.append(message.getStatus());
    sb.append(" result to ");
    sb.append(message.getResult());
    sb.append(":");
    sb.append(message.getMessage());
    logger.info(sb.toString());
  }

  /**
   *  设置普通信息队列尺寸
   * @param size 普通信息队列尺寸
   */
  public void generalMessageQueueSize(int size) {
  }

  /**
   *  设置批量信息队列尺寸
   * @param size 批量信息队列尺寸
   */
  public void massMessageQueueSize(int size) {
  }

  /**
   *  新的普通消息组到来
   * @param bucket 新普通消息组
   */
  public void newGeneralMessageBucket(Queue<TextMessage> bucket) {
    StringBuffer sb=new StringBuffer("New general message bucket with ");
    sb.append(bucket.size());
    sb.append(" messages. ");
    logger.info(sb.toString());
  }

  /**
   *  新的批量消息组到来
   * @param bucket 新批量消息组
   */
  public void newMassMessageBucket(Queue<TextMessage> bucket) {
    StringBuffer sb=new StringBuffer("New mass message bucket with ");
    sb.append(bucket.size());
    sb.append(" messages. :");
    sb.append(bucket.peek().getMessage());
    logger.info(sb.toString());
  }

  /**
   * 获取自上次调用此方法后产生的所有消息状态更新日志
   * @param token 用户访问令牌
   * @return 自上次调用此方法后产生的所有消息状态更新日志
   */
  public List<TextMessageLog> getChangeMessageStatusLog() {
    // TODO Auto-generated method stub
    return null;
  }

  /**
   * 获取当前普通消息队列尺寸
   * @param token 用户访问令牌
   * @return 当前普通消息队列尺寸
   */
  public int getGeneralMessageQueueSize() {
    // TODO Auto-generated method stub
    return 0;
  }

  /**
   * 获取当前批量消息队列尺寸
   * @param token 用户访问令牌
   * @return 当前批量消息队列尺寸
   */
  public int getMassMessageQueueSize() {
    // TODO Auto-generated method stub
    return 0;
  }

  /**
   * 获取自上次调用此方法后产生的所有新普通消息组日志
   * @param token 用户访问令牌
   * @return 自上次调用此方法后产生的所有新普通消息组日志
   */
  public List<MessageBucketLog> getNewGeneralMessageBucketLog() {
    // TODO Auto-generated method stub
    return null;
  }

  /**
   * 获取自上次调用此方法后产生的所有新批量消息组日志
   * @param token 用户访问令牌
   * @return 自上次调用此方法后产生的所有新批量消息组日志
   */
  public List<MessageBucketLog> getNewMassMessageBucketLog() {
    // TODO Auto-generated method stub
    return null;
  }
}