fidstakeworker.java

短信发送

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

import java.io.InputStream;
import java.io.OutputStream;

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

/**
 * <p>Title: FidsTakeWorker</p>
 * <p>Description: </p>
 * @author Lawrence
 * @version 1.0
 */
public class FidsTakeWorker implements QueueWorker {
	private FidsQueue messageQueue = null;
	
	/**
	 * @param messageQueue
	 */
	public FidsTakeWorker(FidsQueue 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 {
	    InputStream bin = null;

	    OutputStream outputStream = object.getOutputStream();
	    if (msgType == REQUEST) {
	      bin = (InputStream) messageQueue.removeRecvFirst();
	    } else if (msgType == RESPONSE) {
	      bin = (InputStream) messageQueue.removeSendFirst();
	    }
	    object.setInputStream(bin);
	    bin.close();
	}

}