[jbosscache-commits] JBoss Cache SVN: r7183 - core/trunk/src/main/java/org/jboss/cache/buddyreplication.

[jbosscache-commits at lists.jboss.org]

Author: mircea.markus
Date: 2008-11-21 11:28:39 -0500 (Fri, 21 Nov 2008)
New Revision: 7183

Modified:
   core/trunk/src/main/java/org/jboss/cache/buddyreplication/BuddyManager.java
Log:
fixed issue

Modified: core/trunk/src/main/java/org/jboss/cache/buddyreplication/BuddyManager.java
===================================================================
--- core/trunk/src/main/java/org/jboss/cache/buddyreplication/BuddyManager.java	2008-11-21 10:28:16 UTC (rev 7182)
+++ core/trunk/src/main/java/org/jboss/cache/buddyreplication/BuddyManager.java	2008-11-21 16:28:39 UTC (rev 7183)
@@ -412,7 +412,9 @@
          if (queue.peek() != STOP_NOTIFIER)
          {
             //first empty the queue.  All queued up view changes that have not been processed yet are now obsolete.
-            queue.clear();
+            /* Do not clear the queue here. It might happen that there is an new memebr added there, which must be
+             * notified about the pool membership.
+             */
             if (trace) log.trace("Enqueueing " + mc + " for async processing");
             queue.put(mc);
          }
@@ -1151,15 +1153,6 @@
       public void run()
       {
          log.trace("Started");
-         // don't start this thread until the Buddy Manager has initialised as it cocks things up.
-         try
-         {
-            initialisationLatch.await();
-         }
-         catch (InterruptedException e)
-         {
-            log.debug("Caught InterruptedException", e);
-         }
          while (!Thread.interrupted() && isRunning)
          {
             try