[jboss-cvs] JBoss Messaging SVN: r8298 - branches/Branch_JBossMessaging_1_4_0_SP3_CP09_JBMESSAGING-1805/src/main/org/jboss/messaging/core/impl/clusterconnection.

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

Author: raggz
Date: 2011-05-05 10:06:06 -0400 (Thu, 05 May 2011)
New Revision: 8298

Modified:
   branches/Branch_JBossMessaging_1_4_0_SP3_CP09_JBMESSAGING-1805/src/main/org/jboss/messaging/core/impl/clusterconnection/MessageSucker.java
Log:
Back port of JBMessaging-1805.


Modified: branches/Branch_JBossMessaging_1_4_0_SP3_CP09_JBMESSAGING-1805/src/main/org/jboss/messaging/core/impl/clusterconnection/MessageSucker.java
===================================================================
--- branches/Branch_JBossMessaging_1_4_0_SP3_CP09_JBMESSAGING-1805/src/main/org/jboss/messaging/core/impl/clusterconnection/MessageSucker.java	2011-05-05 13:43:22 UTC (rev 8297)
+++ branches/Branch_JBossMessaging_1_4_0_SP3_CP09_JBMESSAGING-1805/src/main/org/jboss/messaging/core/impl/clusterconnection/MessageSucker.java	2011-05-05 14:06:06 UTC (rev 8298)
@@ -212,23 +212,6 @@
       
       suspended = true;
 
-      try
-      {
-         consumer.closing(-1);
-      }
-      catch (Throwable t)
-      {
-         // Ignore
-      }
-      try
-      {
-         consumer.close();
-      }
-      catch (Throwable t)
-      {
-         // Ignore
-      }
-
       sourceSession = null;
 
       consumer = null;