[jboss-cvs] JBoss Messaging SVN: r8535 - branches/JBossMessaging_1_4_8_SP5_JBMessaging-1912_JBMessaging-1918_JBMessaging_1921_JBMessaging_1922/src/main/org/jboss/messaging/core/impl/clusterconnection.

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

Author: raggz
Date: 2012-05-09 06:39:54 -0400 (Wed, 09 May 2012)
New Revision: 8535

Modified:
   branches/JBossMessaging_1_4_8_SP5_JBMessaging-1912_JBMessaging-1918_JBMessaging_1921_JBMessaging_1922/src/main/org/jboss/messaging/core/impl/clusterconnection/ClusterConnectionManager.java
Log:
JBMessaging-1921

Modified: branches/JBossMessaging_1_4_8_SP5_JBMessaging-1912_JBMessaging-1918_JBMessaging_1921_JBMessaging_1922/src/main/org/jboss/messaging/core/impl/clusterconnection/ClusterConnectionManager.java
===================================================================
--- branches/JBossMessaging_1_4_8_SP5_JBMessaging-1912_JBMessaging-1918_JBMessaging_1921_JBMessaging_1922/src/main/org/jboss/messaging/core/impl/clusterconnection/ClusterConnectionManager.java	2012-05-09 10:38:44 UTC (rev 8534)
+++ branches/JBossMessaging_1_4_8_SP5_JBMessaging-1912_JBMessaging-1918_JBMessaging_1921_JBMessaging_1922/src/main/org/jboss/messaging/core/impl/clusterconnection/ClusterConnectionManager.java	2012-05-09 10:39:54 UTC (rev 8535)
@@ -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();
 		}
 	}