databasecachedaemonpausedstate.java

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

package com.infobank.superchannel.daemon.databasecache;

import java.util.Queue;
import java.util.concurrent.atomic.AtomicReference;

import com.infobank.superchannel.daemon.GenericState;
import com.infobank.superchannel.daemon.GenericDaemon;
import com.infobank.superchannel.pojo.BlackList;
import com.infobank.superchannel.pojo.TextMessage;

/**
 * @author Xiaoguang Sun
 * @version 类说明: 数据库缓冲服务器暂停状态
 */
public class DatabaseCacheDaemonPausedState extends DatabaseCacheDaemonState {
  // 当前状态说明
  private final static String state="Paused";
  
  /**
   * 私有构造函数，保证此类只能拥有单个实例存在
   */
  private DatabaseCacheDaemonPausedState(){
  }
  
  /**
   * 暂停守护进程
   */
  public boolean pause() {
    return false;
  }

  /**
   * 重新启动守护进程
   */
  public boolean restart() {
    return false;
  }

  /**
   * 继续运行暂停中的守护进程
   */
  public boolean resume() {
    getDaemon().setState(DatabaseCacheDaemonRunningState.getInstance());
    return true;
  }

  /**
   * 启动守护进程
   */
  public boolean start() {
    return false;
  }

  /**
   * 停止守护进程
   */
  public boolean stop() {
    return false;
  }

  /**
   * 取得此状态机的单件实例
   * @return 此状态机的单件实例
   */
  public static DatabaseCacheDaemonState getInstance(){
    return instance.get();
  }

  /**
   * 此状态机的单件实例
   */
  private static AtomicReference<DatabaseCacheDaemonPausedState> instance=new AtomicReference<DatabaseCacheDaemonPausedState>(new DatabaseCacheDaemonPausedState());

  /**
   * 新增待发信息到待发信息队列
   * @param messages 待发消息
   * @param tag message tag
   * @return 操作是否成功
   */
  @Override
  public boolean addNewMessage(Queue<TextMessage> messages, String tag) {
    return false;
  }

  /**
   * 取出信息状态待更新队列中所有状态待更新的信息
   * @return 信息状态待更新队列中所有状态待更新的信息
   */
  @Override
  public Queue<TextMessage> getPendingStatusUpdate() {
    return null;
  }

  /**
   * 将所给信息的新状态更新回数据库
   * @param status 信息新状态更新请求
   * @return 操作是否成功
   */
  @Override
  public boolean updateMessageStatus(Queue<TextMessage> status) {
    return false;
  }

  /**
   * 取出待发短信息队列中所有的信息
   * @param tag message tag
   * @return 待发短信息队列中所有的信息
   */
  @Override
  public Queue<TextMessage> getNewMessage(String tag) {
    return null;
  }

  /**
   * 当前数据库缓冲服务器是否可运行
   * @return 当前数据库缓冲服务器是否可运行
   */
  @Override
  public boolean isRunnable() {
    return false;
  }

  /**
   * 当前数据库缓冲服务器是否出于暂停态
   * @return 当前数据库缓冲服务器是否出于暂停态
   */
  @Override
  public boolean isPaused() {
    return true;
  }

  /**
   * 重新加载守护进程配置
   */
  public boolean reload() {
    return false;
  }
  
  /**
   * 获取守护进程当前状态
   */
  public String getState(){
    return state;
  }

  @Override
  public void setBlackList(BlackList blacklist) {
  }

  @Override
  public boolean newIncomingMessage(Queue<TextMessage> messages) {
    return false;
  }

  @Override
  public Queue<TextMessage> getNewIncomingMessage() {
    return null;
  }
}