[jboss-cvs] jbossmq/src/main/org/jboss/mq Connection.java

[Adrian B. <ej...@us...>]

  User: ejort   
  Date: 04/08/26 11:18:57

  Modified:    src/main/org/jboss/mq Connection.java
  Log:
  Bug Fix [932326] - recreate thread group if it has been destroyed.
  
  Revision  Changes    Path
  1.43      +10 -3     jbossmq/src/main/org/jboss/mq/Connection.java
  
  Index: Connection.java
  ===================================================================
  RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/Connection.java,v
  retrieving revision 1.42
  retrieving revision 1.43
  diff -u -r1.42 -r1.43
  --- Connection.java	9 Aug 2004 22:46:34 -0000	1.42
  +++ Connection.java	26 Aug 2004 18:18:57 -0000	1.43
  @@ -76,7 +76,7 @@
    * @author Hiram Chirino (Coj...@ho...)
    * @author <a href="pr...@ti...">Peter Antman</a>
    * @author <a href="mailto:ad...@jb...">Adrian Brock</a>
  - * @version $Revision: 1.42 $
  + * @version $Revision: 1.43 $
    */
   public abstract class Connection implements Serializable, javax.jms.Connection
   {
  @@ -86,7 +86,7 @@
      private static final long serialVersionUID = 87938199839407082L;
   
      /** The threadGroup */
  -   public static ThreadGroup threadGroup = new ThreadGroup("JBossMQ Client Threads");
  +   private static ThreadGroup threadGroup = new ThreadGroup("JBossMQ Client Threads");
   
      /** The log */
      static Logger log = Logger.getLogger(Connection.class);
  @@ -203,13 +203,20 @@
         {
            public Thread newThread(Runnable r)
            {
  -            Thread t = new Thread(threadGroup, r, "Connection Monitor Thread");
  +            Thread t = new Thread(getThreadGroup(), "Connection Monitor Thread");
               t.setDaemon(true);
               return t;
            }
         });
      }
   
  +   public static ThreadGroup getThreadGroup()
  +   {
  +      if (threadGroup.isDestroyed()) 
  +         threadGroup = new ThreadGroup("JBossMQ Client Threads");
  +      return threadGroup;
  +   }
  +   
      // Constructors --------------------------------------------------
   
      /**