From 01b4cfa2d93ba951d0983bc4cd4b94dd87ea9400 Mon Sep 17 00:00:00 2001
From: Martin Ritchie <ritchiem@apache.org>
Date: Mon, 12 Feb 2007 11:03:12 +0000
Subject: Fixed Xmx value ConcurrentSelectorDeliveryManager : Added trace
 logging. Ensured messages are removed when required, rather than leaking
 memory. AMQSession moved exceptions in recover to wrap method rather than
 individual suspend calls.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/perftesting@506413 13f79535-47bb-0310-9956-ffa450edef68
---
 .../java/org/apache/qpid/client/AMQSession.java     | 21 ++++-----------------
 1 file changed, 4 insertions(+), 17 deletions(-)

(limited to 'qpid/java/client')

diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
index 8dce5d4494..e475270ecd 100644
--- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
+++ b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
@@ -812,15 +812,9 @@ public class AMQSession extends Closeable implements Session, QueueSession, Topi
 
             if (!isSuspended)
             {
-                try
-                {
-                    suspendChannel(true);
-                }
-                catch (AMQException e)
-                {
-                    throw new JMSAMQException(e);
-                }
+                suspendChannel(true);
             }
+
             for (BasicMessageConsumer consumer : _consumers.values())
             {
                 consumer.clearUnackedMessages();
@@ -839,17 +833,10 @@ public class AMQSession extends Closeable implements Session, QueueSession, Topi
             {
                 _dispatcher.rollback();
             }
-                                   
+
             if (!isSuspended)
             {
-                try
-                {
-                    suspendChannel(false);
-                }
-                catch (AMQException e)
-                {
-                    throw new JMSAMQException(e);
-                }
+                suspendChannel(false);
             }
         }
         catch (AMQException e)
-- 
cgit v1.2.1