recvqueue.java

java支持的短信平台

package com.khan.sms.cmpp2control;

import java.util.Vector;
import com.khan.sms.cmpp2.Cmpp2Data;

/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: </p>
 *
 * @author not attributable
 * @version 1.0
 */
public class RecvQueue {
    private static RecvQueue _instance;
    public Vector Cmpp_DataQueue;
    private int Size;


    private RecvQueue(int size) {
      Size = size;
      Cmpp_DataQueue = new Vector(Size);
    }

    public static synchronized RecvQueue getInstance() {
        if (_instance == null) {
            CmppParam cp = CmppParam.getInstance();
            int size = cp.MAX_RECVQUEUE_SIZE;
            _instance = new RecvQueue(size);
        }
        return _instance;
    }

    public synchronized boolean put(Cmpp2Data data){
      //System.out.println("Debug:recvQueue CommondID"+MsgID.toHexString(MsgID.toByteArray(data.CommandID)));

      if (Cmpp_DataQueue.size() < Size){
          Cmpp_DataQueue.add(data);
          return true;
      }
      return false;
    }

    public synchronized Cmpp2Data get() {
        if (this.Cmpp_DataQueue.size() > 0)
            return (Cmpp2Data) Cmpp_DataQueue.remove(0);
        else
            return null;
    }
}