/*

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

  */

 package org.apache.commons.messenger;

 import javax.jms.JMSException;

 import javax.jms.ServerSession;

 import javax.jms.Session;

 /** <p><code>DefaultServerSession</code> is a default implementation of

   * the JMS ServerSession interface.</p>

   *

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

   * @version $Revision: 155459 $

   */

 public class DefaultServerSession extends Thread implements ServerSession {

     /** The JMS Session on which this ServerSession is based */

     private Session session;

     /** Indicates whether the session has been started */

     private boolean started = false;

     public DefaultServerSession(Session session) throws JMSException {

         this.session = session;

     }

     /**

      * Return the ServerSession's Session. This must be a Session

      * created by the same Connection which will be dispatching messages

      * to it. The provider will assign one or more messages to the Session

      * and then call start on the ServerSession.

      *

      * @return the server session's session.

      *

      * @exception JMSException if a JMS error occurs.

      */

     public Session getSession() throws JMSException {

         return session;

     }

     /** 

      * Cause the session's run method to be called to process messages

      * that were just assigned to it.

      *

      */

     public synchronized void start() {

         if ( ! started  ) {

             started = true;

             super.start();

         }

     }

     public void run() {

         session.run();

     }

 }