def handle_ConnectionClose(self, frame):
<EOL>self.sender.send_CloseOK()<EOL>exc = ConnectionClosed(frame.payload.reply_text,<EOL>frame.payload.reply_code)<EOL>self._close_all(exc)<EOL>self.protocol.close()<EOL>
AMQP server closed the channel with an error