queueaddworker.java

《JAVA实用系统开发指南》随书光盘源代码

package com.jdon.jserver.connector.data;

import java.io.*;

import com.jdon.jserver.connector.queue.MessageQueue;

/**
 * 一个访问者具体子类
 * <p>Copyright: Jdon.com Copyright (c) 2003</p>
 * <p>Company: 上海解道计算机技术有限公司</p>
 * @author banq
 * @version 1.0
 */
public class QueueAddWorker implements QueueWorker{

    private MessageQueue messageQueue = null;

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

    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);
      }
    }

}