[jboss-cvs] JBoss Messaging SVN: r6202 - trunk/src/main/org/jboss/messaging/core/client/impl.

[jboss-cvs-commits at lists.jboss.org]

Author: ataylor
Date: 2009-03-27 13:12:41 -0400 (Fri, 27 Mar 2009)
New Revision: 6202

Modified:
   trunk/src/main/org/jboss/messaging/core/client/impl/ClientConsumerImpl.java
Log:
sync fix for stop

Modified: trunk/src/main/org/jboss/messaging/core/client/impl/ClientConsumerImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/client/impl/ClientConsumerImpl.java	2009-03-27 16:51:58 UTC (rev 6201)
+++ trunk/src/main/org/jboss/messaging/core/client/impl/ClientConsumerImpl.java	2009-03-27 17:12:41 UTC (rev 6202)
@@ -296,14 +296,17 @@
       return directory != null;
    }
 
-   public synchronized void stop() throws MessagingException
+   public void stop() throws MessagingException
    {
-      if (stopped)
+      waitForOnMessageToComplete();
+      synchronized (this)
       {
-         return;
+         if (stopped)
+         {
+            return;
+         }
+         stopped = true;
       }
-      stopped = true;
-      waitForOnMessageToComplete();
    }
 
    public synchronized void start()