[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