/*

  * 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: MessageServletDispatcher.java 155459 2005-02-26 13:24:44Z dirkv $

  */

 package org.apache.commons.messagelet.impl;

 import javax.jms.JMSException;

 import javax.jms.Message;

 import javax.servlet.ServletException;

 import org.apache.commons.messagelet.MessageDrivenObjectSupport;

 import org.apache.commons.messenger.Messenger;

 import org.apache.commons.messenger.MessengerListener;

 /** <p><code>MessageDispatcher</code> dispatches JMS Messages

   * into a Servlet engine for procesing.</p>

   *

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

   * @version $Revision: 155459 $

   */

 public class MessageServletDispatcher extends MessageDrivenObjectSupport implements MessengerListener {

     /**

      * The ServletRequest object we will pass to the servlet engine

      */

     private MessageletRequestImpl request;

     /**

      * The ServletResponse object we will pass to the servlet engine

      */

     private MessageletResponseImpl response;

     /** 

      * The reply to messenger

      */

     private Messenger messenger;

     /** Holds value of property path. */

     private String path;    

     public MessageServletDispatcher() {

         //request.setResponse(response);

         //response.setRequest(request);        

     }

     public MessageServletDispatcher(String path) {

         this();

         this.path = path;

     }

     public void init() throws ServletException {

         request = new MessageletRequestImpl( new ServletRequestImpl( getServletContext() ) );

         response = new MessageletResponseImpl( new ServletResponseImpl() );

     }

     // MessengerListener methods

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

     public void setMessenger(Messenger messenger) {

         response.setReplyMessenger( messenger );

     }

     /**

      * Process the incoming JMS Message.

      *

      * @param message is the message to be processed

      */

     public void onMessage(Message message) {

         try {

             response.setReplyToDestination( message.getJMSReplyTo() );

         }

         catch (JMSException e) {

             log( "Could not find JMS replyTo destination", e );

             response.setReplyToDestination( null );

         }

         // Ask our Container to process this request

         try {

             // initialise the request

             request.setMessage( message );

             response.reset();

             // dispatch the servlet

             getServletContext().getRequestDispatcher( getPath() ).include(request, response);

             // finish up the response, sending a reply if necessary

             response.finish();

         } 

         catch (Throwable e) {

             handleException( message, e );

         }

     }

     // Properties

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

     /** Getter for property path.

      * @return Value of property path.

      */ 

     public String getPath() {

         return path;

     }

     /** Setter for property path.

      * @param path New value of property path.

      */

     public void setPath(String path) {

         this.path = path;

         //request.setRequestURI(path);

     }

     // Implementation methods

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

     protected void handleException(Message message, Throwable t) {

         log( "Caught exception processing message: " + message, t);

     }

 }