docs: def on_open(self, _handle):
          """Invoked when the connection is opened
  
          :type _handle: pika.adapters.tornado_connection.TornadoConnection
  
          """
          self.logger.debug('Connection opened')
          self.handle.add_on_connection_blocked_callback(self.on_blocked)
          self.handle.add_on_connection_unblocked_callback(self.on_unblocked)
          self.handle.add_on_close_callback(self.on_closed)
          self.handle.channel(self.on_channel_open)