diff options
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java | 6 |
1 files changed, 3 insertions, 3 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 d919504185..ce624cb91b 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 @@ -3214,11 +3214,11 @@ public abstract class AMQSession<C extends BasicMessageConsumer, P extends Basic { synchronized (_lock) { - boolean stopped = _dispatcher.connectionStopped(); + boolean stopped = connectionStopped(); if (!stopped) { - _dispatcher.setConnectionStopped(true); + setConnectionStopped(true); } // Reject messages on pre-receive queue @@ -3231,7 +3231,7 @@ public abstract class AMQSession<C extends BasicMessageConsumer, P extends Basic // closeConsumer consumer.markClosed(); - _dispatcher.setConnectionStopped(stopped); + setConnectionStopped(stopped); } } |