messagelauncherdaemonrunningtostoppedtransitionstate.java

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

package com.infobank.superchannel.daemon.messagelauncher;

import java.rmi.NotBoundException;
import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
import java.util.Queue;
import java.util.concurrent.atomic.AtomicReference;

import org.apache.commons.configuration.Configuration;

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

/**
 * @author Xiaoguang Sun
 * @version 类说明: 消息发送服务器运行到停止切换态的状态机
 */
public class MessageLauncherDaemonRunningToStoppedTransitionState extends
    MessageLauncherDaemonState {
  // 当前状态说明
  private final static String state="Running"; 

  /**
   * 暂停守护进程
   */
  public boolean pause() {
    // TODO Auto-generated method stub
    return false;
  }

  /**
   * 重新启动守护进程
   */
  public boolean restart() {
    // TODO Auto-generated method stub
    return false;
  }

  /**
   * 继续运行暂停中的守护进程
   */
  public boolean resume() {
    // TODO Auto-generated method stub
    return false;
  }

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

  /**
   * 停止守护进程
   */
  public boolean stop() {
    // TODO Auto-generated method stub
    return false;
  }

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

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

  /**
   * 新增短消息到消息队列
   * @param messages 新的待发短信息 
   */
  @Override
  public void addMessage(Queue<TextMessage> messages) {
    getDaemon().stateAddMessage(messages);
  }

  /**
   * 从数据库缓冲服务器获取新的待发短信息
   * @return 新的待发短信息
   */
  @Override
  public Queue<TextMessage> fetchNewMessage() {
    return null;
  }

  /**
   * 新增短消息状态变更请求到等待队列
   * @param message 状态更新的短消息 
   */
  @Override
  public void addStatusUpdate(TextMessage message) {
    // TODO Auto-generated method stub
    
  }

  /**
   * 将状态更新请求队列内所有待更新项目发送给数据库缓冲服务器
   * @return 操作是否成功
   */
  @Override
  public boolean updateMessageStatus() {
    // TODO Auto-generated method stub
    return false;
  }

  /**
   * 从普通消息队列取出一定数量的消息待发
   * @return 一批新消息
   */
  @Override
  public Queue<TextMessage> getGeneralMessage(int number) {
    // TODO Auto-generated method stub
    return null;
  }

  /**
   * 从普通消息队列取出一条消息待发
   * @return 新消息
   */
  @Override
  public TextMessage getGeneralMessage() {
    // TODO Auto-generated method stub
    return null;
  }

  /**
   * 从批量消息队列取出一定数量的消息待发
   * @return 一批新消息
   */
  @Override
  public Queue<TextMessage> getMassMessage(int number) {
    // TODO Auto-generated method stub
    return null;
  }

  /**
   * 从批量消息队列取出一条消息待发
   * @return 新消息
   */
  @Override
  public TextMessage getMassMessage() {
    // TODO Auto-generated method stub
    return null;
  }

  /**
   * 当前信息发送服务器是否出于暂停态
   * @return 当前信息发送服务器是否出于暂停态
   */
  @Override
  public boolean isPaused() {
    return false;
  }

  /**
   * 当前信息发送服务器是否可运行
   * @return 当前信息发送服务器是否可运行
   */
  @Override
  public boolean isRunnable() {
    return true;
  }

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

  @Override
  public boolean newIncomingMessage(TextMessage message) {
    // TODO Auto-generated method stub
    return false;
  }

  @Override
  public void saveIncomingMessage() {
  }
}