[jboss-cvs] JBoss Messaging SVN: r8080 - in branches/Branch_JBossMessaging_1_4_0_SP3_CP10_JBMESSAGING-1805: src/main/org/jboss/messaging/core/impl/clusterconnection and 1 other directory.

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

Author: jbertram at redhat.com
Date: 2010-08-12 12:11:50 -0400 (Thu, 12 Aug 2010)
New Revision: 8080

Modified:
   branches/Branch_JBossMessaging_1_4_0_SP3_CP10_JBMESSAGING-1805/.classpath
   branches/Branch_JBossMessaging_1_4_0_SP3_CP10_JBMESSAGING-1805/src/main/org/jboss/messaging/core/impl/clusterconnection/MessageSucker.java
Log:
JBPAPP-4866

Modified: branches/Branch_JBossMessaging_1_4_0_SP3_CP10_JBMESSAGING-1805/.classpath
===================================================================
--- branches/Branch_JBossMessaging_1_4_0_SP3_CP10_JBMESSAGING-1805/.classpath	2010-08-10 21:06:42 UTC (rev 8079)
+++ branches/Branch_JBossMessaging_1_4_0_SP3_CP10_JBMESSAGING-1805/.classpath	2010-08-12 16:11:50 UTC (rev 8080)
@@ -1,7 +1,8 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <classpath>
 	<classpathentry kind="src" path="docs/examples/queue-failover/src"/>
-	<classpathentry kind="src" path="integration/EAP4/src"/>
+	<classpathentry kind="src" path="jgroups-src"/>
+	<classpathentry kind="src" path="integration/EAP4/src/main"/>
 	<classpathentry kind="src" path="integration/EAP4/tests-src"/>
 	<classpathentry kind="src" path="docs/examples/bridge/src"/>
 	<classpathentry kind="src" path="docs/examples/stateless-clustered/src"/>

Modified: branches/Branch_JBossMessaging_1_4_0_SP3_CP10_JBMESSAGING-1805/src/main/org/jboss/messaging/core/impl/clusterconnection/MessageSucker.java
===================================================================
--- branches/Branch_JBossMessaging_1_4_0_SP3_CP10_JBMESSAGING-1805/src/main/org/jboss/messaging/core/impl/clusterconnection/MessageSucker.java	2010-08-10 21:06:42 UTC (rev 8079)
+++ branches/Branch_JBossMessaging_1_4_0_SP3_CP10_JBMESSAGING-1805/src/main/org/jboss/messaging/core/impl/clusterconnection/MessageSucker.java	2010-08-12 16:11:50 UTC (rev 8080)
@@ -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;