/*

  * Copyright (C) The Apache Software Foundation. All rights reserved.

  *

  * This software is published under the terms of the Apache Software License

  * version 1.1, a copy of which has been included with this distribution in

  * the LICENSE file.

  * 

  * $Id: HttpMessageletRequestImpl.java 155459 2005-02-26 13:24:44Z dirkv $

  */

 package org.apache.commons.messagelet.impl;

 import java.io.BufferedReader;

 import java.io.InputStreamReader;

 import javax.jms.JMSException;

 import javax.jms.Message;

 import javax.jms.TextMessage;

 import javax.servlet.ServletInputStream;

 import javax.servlet.http.HttpServletRequest;

 import javax.servlet.http.HttpServletRequestWrapper;

 import org.apache.commons.messagelet.MessageletRequest;

 import org.apache.commons.messenger.Messenger;

 /** <p><code>HttpMessageletRequestImpl</code> represents a servlet request from

   * a JMS Message source which appears to be a HTTP request so that JSP can process

   * the request as if it were a HTTP request.</p>

   *

   * @author <a href="mailto:jstrachan@apache.org">James Strachan</a>

   * @version $Revision: 155459 $

   */

 public class HttpMessageletRequestImpl extends HttpServletRequestWrapper implements MessageletRequest {

     /** The Message which caused this request */

     private Message message;

     /** The stream to read the body of the current Message */

     private ServletInputStream stream;

     public HttpMessageletRequestImpl(HttpServletRequest request) {

         super(request);

     }

     public void setMessage(Message message) throws JMSException {

         this.message = message;

         this.stream = createInputStream();

         // also publish the message as a request scope attribute

         setAttribute( "message", message );

     }

     public void setMessenger(Messenger messenger) {

         setAttribute( "messenger", messenger );

     }

     // MessageletRequest methods

     //-------------------------------------------------------------------------    

     /** @return the Message which originated this request */

     public Message getMessage() {

         return message;

     }

     // ServletRequest methods

     //-------------------------------------------------------------------------    

     public ServletInputStream getInputStream() {

         return stream;

     }

     public BufferedReader getReader() {

         return new BufferedReader( new InputStreamReader( stream ) );

     }

     // Implementation methods

     //-------------------------------------------------------------------------    

     protected ServletInputStream createInputStream() throws JMSException {

         if ( message instanceof TextMessage ) {

             TextMessage textMessage = (TextMessage) message;

             return new BufferedServletInputStream( textMessage.getText() );

         }

         // ##### handle ByteMessage and StreamMessage somehow one day?

         return new BufferedServletInputStream();

     }

 }