emailaddworker.java

短信发送

/**
 * Created at Dec 4, 2008
 */
package com.jdev.app.db.queue;

import java.io.OutputStream;

import com.jdev.net.data.Linkable;
import com.jdev.net.data.QueueWorker;

/**
 * <p>Title: EmailAddWorker</p>
 * <p>Description: </p>
 * @author Lawrence
 * @version 
 */
public class EmailAddWorker implements QueueWorker {
	private EmailQueue messageQueue = null;

	/**
	 * @param messageQueue
	 */
	public EmailAddWorker(EmailQueue messageQueue) {
		this.messageQueue = messageQueue;
	}

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

}