diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2007-02-12 11:03:12 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2007-02-12 11:03:12 +0000 |
| commit | 01b4cfa2d93ba951d0983bc4cd4b94dd87ea9400 (patch) | |
| tree | 9ee7bd19e52a62407197840f76f9ff83ebb9097b /qpid/java/client | |
| parent | 83d11a1e4deb2bd5e76d893dbedfe97d4241b2ad (diff) | |
| download | qpid-python-01b4cfa2d93ba951d0983bc4cd4b94dd87ea9400.tar.gz | |
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
Diffstat (limited to 'qpid/java/client')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java | 21 |
1 files changed, 4 insertions, 17 deletions
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) |