mtsender.java

Logica lastest SMPP API

package com.smpp.server;

import com.logica.smpp.pdu.SubmitSMResp;
import com.logica.smpp.util.Queue;

public class MTSender
{
	private static Queue queue;
	private static int seq = 1000;

	public MTSender()
	{
		ResponseQueue rq = ResponseQueue.getResponseQueue();
		queue = rq.getQueue();
	}
	

	

	public void sendMessage(Message message)
	{
		MTSenderQueue sq = MTSenderQueue.getMTSenderQueue();
		sq.setMessageInQueue(message);
	}

	public ResponseMessage receiveResponses()
	{
		ResponseMessage rm = null;
		//System.out.println("Receiving Response");
		long b = System.currentTimeMillis();
		while (!isResponseAvailable())
		{
			try
			{
				Thread.sleep(3);
			} catch (InterruptedException e)
			{
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		long c = System.currentTimeMillis();
		//System.out.println("Total sleep time :"+ (c-b));
			//System.out.println("Queue Size :"+queue.size());
			SubmitSMResp resp = (SubmitSMResp) queue.dequeue();
			//System.out.println("Sequence No Received :"+resp.getSequenceNumber());
			rm = new ResponseMessage(resp);
		
		
		return rm;
	}

	public boolean isResponseAvailable()
	{
		return (queue.size() > 0) ? true : false;
	}

}