[jboss-cvs] jboss/src/main/org/jboss/ejb/plugins/jms JMSContainerInvoker.java

[Scott M S. <st...@us...>]

  User: starksm 
  Date: 02/07/27 21:14:38

  Modified:    src/main/org/jboss/ejb/plugins/jms JMSContainerInvoker.java
  Log:
  - Move the access any JMS destinations to startService
  - Fix the destroyService name so the invoker is properly shutdown
  
  Revision  Changes    Path
  1.50      +22 -17    jboss/src/main/org/jboss/ejb/plugins/jms/JMSContainerInvoker.java
  
  Index: JMSContainerInvoker.java
  ===================================================================
  RCS file: /cvsroot/jboss/jboss/src/main/org/jboss/ejb/plugins/jms/JMSContainerInvoker.java,v
  retrieving revision 1.49
  retrieving revision 1.50
  diff -u -r1.49 -r1.50
  --- JMSContainerInvoker.java	27 Jul 2002 20:06:07 -0000	1.49
  +++ JMSContainerInvoker.java	28 Jul 2002 04:14:38 -0000	1.50
  @@ -54,7 +54,7 @@
   /**
    * EJBProxyFactory for JMS MessageDrivenBeans
    *
  - * @version <tt>$Revision: 1.49 $</tt>
  + * @version <tt>$Revision: 1.50 $</tt>
    * @author <a href="mailto:pet...@ti...">Peter Antman</a> .
    * @author <a href="mailto:ric...@te...">Rickard Öberg</a>
    * @author <a href="mailto:seb...@m4...">Sebastien Alborini</a>
  @@ -370,20 +370,6 @@
         //
         
         exListener = new ExceptionListenerImpl(this);
  -      try {
  -          innerCreate();
  -      }
  -      catch (final JMSException e) {
  -      	 //
  -      	 // start a thread up to handle recovering the connection. so we can
  -         // attach to the jms resources once they become available
  -         //
  -      	 new Thread("JMSContainerInvoker Create Recovery Thread") {
  -            public void run() {
  -               exListener.onException(e);
  -            }
  -      	 }.start();
  -      }
      }
   
      /**
  @@ -562,6 +548,25 @@
      
      protected void startService() throws Exception
      {
  +      try
  +      {
  +          innerCreate();
  +      }
  +      catch (final JMSException e)
  +      {
  +      	 //
  +      	 // start a thread up to handle recovering the connection. so we can
  +         // attach to the jms resources once they become available
  +         //
  +      	 new Thread("JMSContainerInvoker Create Recovery Thread")
  +         {
  +            public void run()
  +            {
  +               exListener.onException(e);
  +            }
  +      	 }.start();
  +      }
  +
         if (dlqHandler != null)
         {
            dlqHandler.start();
  @@ -623,14 +628,14 @@
         }
      }
      
  -   protected void destoryService() throws Exception
  +   protected void destroyService() throws Exception
      {
         // Take down DLQ
         if (dlqHandler != null)
         {
            dlqHandler.destroy();
         }
  -      
  +
         // close the connection consumer
         try
         {