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

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

Author: gaohoward
Date: 2011-02-17 10:36:14 -0500 (Thu, 17 Feb 2011)
New Revision: 8229

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


Modified: branches/JBM1842/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java
===================================================================
--- branches/JBM1842/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java	2011-02-16 15:40:25 UTC (rev 8228)
+++ branches/JBM1842/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java	2011-02-17 15:36:14 UTC (rev 8229)
@@ -674,6 +674,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