diff options
Diffstat (limited to 'qpid/java/client/src/main')
| -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) |