summaryrefslogtreecommitdiff
path: root/java
diff options
context:
space:
mode:
authorMartin Ritchie <ritchiem@apache.org>2007-05-17 13:26:25 +0000
committerMartin Ritchie <ritchiem@apache.org>2007-05-17 13:26:25 +0000
commit56620da8293fb5b6a4fab5d950ea2037629815ac (patch)
treeed0ee2da4ef3188a330c442346c300521b82148a /java
parentc0908c3a2c22fcc99474f9dad27b6f94442e65c9 (diff)
downloadqpid-python-56620da8293fb5b6a4fab5d950ea2037629815ac.tar.gz
Fixed failing python tests. The rather annoying way we unsubscribe subscribers by creating new ones was causing a problem as the closing channel had been closed before the unsubscribe call.
Java now passes all python tests git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@538912 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java')
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java8
1 files changed, 7 insertions, 1 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java b/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
index 9f803558d1..52e9505a32 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
@@ -357,10 +357,16 @@ public class AMQChannel
*/
public void close(AMQProtocolSession session) throws AMQException
{
- _closing = true;
_txnContext.rollback();
unsubscribeAllConsumers(session);
requeue();
+
+ setClosing(true);
+ }
+
+ private void setClosing(boolean closing)
+ {
+ _closing = closing;
}
private void unsubscribeAllConsumers(AMQProtocolSession session) throws AMQException