databasecachestatusobserver.java

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

package com.infobank.superchannel.observer;

import java.util.LinkedList;
import java.util.List;

import com.infobank.superchannel.pojo.*;

/**
 * @author Xiaoguang Sun
 * @version 类说明: 数据库缓冲服务器状态观察者接口
 */
public interface DatabaseCacheStatusObserver extends LogObserver{
  /**
   * 从数据库中取出一条新待发短消息
   * @param message 新待发短消息
   */
  void newMessage(TextMessage message);

  /**
   *  过滤掉一条短消息
   * @param message 被过滤掉的短消息
   */
  void blockMessage(TextMessage message);
  
  /**
   * new incoming message
   */
  void newIncomingMessage(TextMessage message);

  /**
   * 将一条短消息的状态更新回写回数据库
   * @param message 状态更新的短消息
   */
  void updateMessageStatus(TextMessage message);

  /**
   *  重新读取黑名单
   * @param list 黑名单
   */
  void reloadBlackList(BlackList list);

  /**
   *  有一条状态更新的短信被添加到待更新请求队列
   * @param message 状态更新的短信
   */
  void newMessageStatus(TextMessage message);

  /**
   * 设置新的消息队列尺寸
   * @param size 新尺寸
   */
  void messageQueueSize(int size);

  /**
   * 设置新的状态更新等待队列尺寸
   * @param size 新尺寸
   */
  void statusQueueSize(int size);

  /**
   * setup new incoming message update queue
   * @param size new size
   */
  void incomingMessageQueueSize(int size);
  
  /**
   * 设置累计发送失败的短信息条数
   * @param number 累计发送失败的短信息条数
   */
  void numberOfFailedMessages(int number);

  /**
   * 设置累计发送成功的短信息条数
   * @param number 累计发送成功的短信息条数
   */
  void numberOfSuccessfulMessages(int number);

  /**
   * 取得自上次调用此方法后被过滤掉的短信息内容日志
   * @return 自上次调用此方法后被过滤掉的短信息内容日志
   */
  public List<TextMessageLog> getBlockMessageLog();
  
  /**
   * 取得自上次调用此方法后从数据库中取出的待发短信息日志
   * @return 自上次调用此方法后从数据库中取出的待发短信息日志
   */
  public List<TextMessageLog> getNewMessageLog();
  
  /**
   * 取得自上次调用此方法后被过短信息状态被回写回数据库的日志
   * @return 自上次调用此方法后被过短信息状态被回写回数据库的日志
   */
  public List<TextMessageLog> getUpdateMessageLog();

  /**
   * 取得自上次调用此方法后新增短信息状态更新请求的日志
   * @return 自上次调用此方法后新增短信息状态更新请求的日志
   */
  public List<TextMessageLog> getNewMessageStatusLog();

  /**
   * 取得自上次调用此方法后新增Incoming短信息的日志
   * @return 自上次调用此方法后新增Incoming短信息的日志
   */
  public List<TextMessageLog> getNewIncomingMessageLog();

  /**
   * 取得自上次调用此方法后所有黑名单更新日志
   * @return 自上次调用此方法后所有黑名单更新日志
   */
  public List<BlackListLog> getBlackListLog();
  
  /**
   * 取得待发消息队列尺寸
   * @return 待发消息队列尺寸
   */
  public int getMessageQueueSize();
  
  /**
   * 取得Incoming消息队列尺寸
   * @return 待发消息队列尺寸
   */
  public int getIncomingMessageQueueSize();

  /**
   * 取得累计发送失败短信息数目
   * @return 累计发送失败短信息数目
   */
  public int getNumberOfFailedMessages();
  
  /**
   * 取得累计发送成功短信息数目
   * @return 累计发送成功短信息数目
   */
  public int getNumberOfSuccessfulMessages();
  
  /**
   * 取得状态更新回写队列尺寸
   * @return 状态更新回写队列尺寸
   */
  public int getStatusQueueSize();
}