testput.java

短信开发用于文件交换处理转发的类模块

package com.sms.platform.switchcenter.inner.reportrespqueue;

import org.apache.log4j.Logger;

import com.pub.util.FileUtils;
import com.sms.protocol.standard12.Standard_Inner_Response;

public class TestPut   extends Thread{

	private static Logger log = Logger.getLogger(TestPut.class);
	
	public void run(){
		TestGlobal global = TestGlobal.getInstance();
        Standard_Inner_Response sir = null;
        
        log.debug("count : " + global.getRespQueue().count());
        for(int i = 1 ; i < 500; i++){
        	sir = new Standard_Inner_Response();
        	sir.setSequenceId(i);
        	sir.setMessageID(i+"");
        	sir.setSrcClientID(1);
        	sir.setState(i);
        	int state = global.getRespQueue().put(sir);
        	log.debug("Put " + i + " " + state + " " + sir.getMessageID()+"|"+sir.getSrcClientID()+"|"+sir.getSequenceId()+"|"+sir.getState());
        }
        log.debug("Put count : " + global.getRespQueue().count());
	}
	
	public TestPut(){

	}
	
	public static void main(String [] args){
		new TestPut();
	}

}