[jboss-cvs] JBoss Messaging SVN: r8230 - branches/port1842/src/main/org/jboss/messaging/core/impl/postoffice.

jboss-cvs-commits at lists.jboss.org jboss-cvs-commits at lists.jboss.org
Thu Feb 17 10:39:08 EST 2011


Author: gaohoward
Date: 2011-02-17 10:39:08 -0500 (Thu, 17 Feb 2011)
New Revision: 8230

Modified:
   branches/port1842/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java
Log:
added delay to avoid multicasting at jgroups flush time


Modified: branches/port1842/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java
===================================================================
--- branches/port1842/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java	2011-02-17 15:36:14 UTC (rev 8229)
+++ branches/port1842/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java	2011-02-17 15:39:08 UTC (rev 8230)
@@ -663,6 +663,15 @@
             View currView = groupMember.getCurrentView();
             if ((currView != null) && currView.getMembers().size() > 1)
             {
+               //here we sleep for 5 sec to allow flush finish
+               try
+               {
+                  Thread.sleep(5000);
+               }
+               catch (InterruptedException e)
+               {
+                  //ignore
+               }
                PostOfficeAddressInfo info = new PostOfficeAddressInfo(groupMember.getControlChannelAddress(),
                                                                       groupMember.getDataChannelAddress());
                try



More information about the jboss-cvs-commits mailing list