sendnotehandlethread.java

java 编写的短信平台。支持所有协议

package com.sf.note;

import java.io.IOException;


import com.huawei.insa2.comm.cmpp.message.CMPPMessage;
import com.huawei.insa2.comm.cmpp.message.CMPPSubmitRepMessage;
import com.huawei.insa2.comm.cmpp30.message.CMPP30SubmitRepMessage;





public class SendNoteHandleThread  extends AbstractNoteHandleThread {
	
	

	public void process() {
		CMPPMessage message = null;
		while (!isStop) {
			try {
				if (QueueInstance.sendQueue == null)
	            {
					QueueInstance.sendQueue = new Queue();
	                continue;
	            }
				while (QueueInstance.sendQueue.getQueueSize() == 0)
				{
				    synchronized(QueueInstance.sendQueue)
				    {
				    	QueueInstance.sendQueue.wait();
				    }
				    continue;
				}
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
			try {
				Object m = QueueInstance.sendQueue.get();
				
				if (m != null && m instanceof CMPPMessage) {
	
				   message = (CMPPMessage)m;
				   sendMessage(message);
				}
			} catch(Exception e) {
				e.printStackTrace();
				continue;
			}
			
		}
		
	}
	
	private Cmpp20Proxy cmpp20Proxy = null;
	
	public void setCmpp20Proxy(Cmpp20Proxy cmpp20Proxy) {
		this.cmpp20Proxy = cmpp20Proxy;
	}
	
	private Cmpp30Proxy cmpp30Proxy = null;
	
	public void setCmpp30Proxy(Cmpp30Proxy cmpp30Proxy) {
		this.cmpp30Proxy = cmpp30Proxy;
	}
	
	private synchronized void sendMessage(CMPPMessage message) throws IOException {
		if (cmpp20Proxy != null) {
			//message.setSequenceId(1);
			CMPPSubmitRepMessage res = (CMPPSubmitRepMessage)cmpp20Proxy.send(message);
			System.out.println(res.getResult());
		}
		if (cmpp30Proxy != null) {
			CMPP30SubmitRepMessage res = (CMPP30SubmitRepMessage)cmpp30Proxy.send(message);
			System.out.println(res.getResult());
		}
	}

}