queueaddworker.java

短信发送

/**
 * Created at Nov 20, 2008
 */
package com.jdev.net.data;

import java.io.OutputStream;

import com.jdev.net.queue.MessageQueue;

/**
 * <p>Title: QueueAddWorker</p>
 * <p>Description: </p>
 * @author Lawrence
 * @version 1.0
 */
public class QueueAddWorker implements QueueWorker {

	private MessageQueue messageQueue = null;

	public QueueAddWorker(MessageQueue messageQueue) {
		this.messageQueue = messageQueue;
	}

	/* (non-Javadoc)
	 * @see com.jdev.net.data.QueueWorker#run(int, com.jdev.net.data.Linkable)
	 */
	public void run(int msgType, Linkable object) throws Exception {
		OutputStream outputStream = object.getOutputStream();
		if (msgType == REQUEST) {
			messageQueue.pushRequest(outputStream);
		} else if (msgType == RESPONSE) {
			messageQueue.pushResponse(outputStream);
		}
	}

}