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