[jboss-cvs] JBoss Messaging SVN: r8526 - branches/Branch_1_4/src/main/org/jboss/messaging/core/impl/clusterconnection.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Wed Apr 18 11:24:34 EDT 2012
Author: gaohoward
Date: 2012-04-18 11:24:34 -0400 (Wed, 18 Apr 2012)
New Revision: 8526
Modified:
branches/Branch_1_4/src/main/org/jboss/messaging/core/impl/clusterconnection/ClusterConnectionManager.java
Log:
JBMESSAGING-1921
Modified: branches/Branch_1_4/src/main/org/jboss/messaging/core/impl/clusterconnection/ClusterConnectionManager.java
===================================================================
--- branches/Branch_1_4/src/main/org/jboss/messaging/core/impl/clusterconnection/ClusterConnectionManager.java 2012-04-16 04:22:28 UTC (rev 8525)
+++ branches/Branch_1_4/src/main/org/jboss/messaging/core/impl/clusterconnection/ClusterConnectionManager.java 2012-04-18 15:24:34 UTC (rev 8526)
@@ -525,15 +525,21 @@
return;
}
- MessageSucker sucker = info.removeSucker(queueName);
+ final MessageSucker sucker = info.removeSucker(queueName);
if (sucker == null)
{
//This is OK too
}
else
- {
- sucker.stop();
+ {
+ new Thread()
+ {
+ public void run()
+ {
+ sucker.stop();
+ }
+ }.start();
}
}
More information about the jboss-cvs-commits
mailing list