From 5b50014477ef0b9096c017af8fb85ac5693e673e Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Wed, 4 Feb 2009 20:47:14 +0000 Subject: Fix assertion due to doOutput control being sent after local connection closed. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@740872 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/cluster/Connection.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'cpp/src/qpid/cluster/Connection.cpp') diff --git a/cpp/src/qpid/cluster/Connection.cpp b/cpp/src/qpid/cluster/Connection.cpp index a71950ef1d..2a831ae435 100644 --- a/cpp/src/qpid/cluster/Connection.cpp +++ b/cpp/src/qpid/cluster/Connection.cpp @@ -112,7 +112,7 @@ void Connection::received(framing::AMQFrame& f) { cluster.addShadowConnection(this); AMQFrame ok((ConnectionCloseOkBody())); connection.getOutput().send(ok); - output.setOutputHandler(discardHandler); + output.closeOutput(discardHandler); catchUp = false; } else @@ -165,7 +165,7 @@ void Connection::closed() { // This was a local replicated connection. Multicast a deliver // closed and process any outstanding frames from the cluster // until self-delivery of deliver-close. - output.setOutputHandler(discardHandler); + output.closeOutput(discardHandler); cluster.getMulticast().mcastControl(ClusterConnectionDeliverCloseBody(), self); } } -- cgit v1.2.1