code: def on_connected(self, connection):
          
          log.info('PikaClient: connected to RabbitMQ')
          self.connected = True
          self.in_channel = self.connection.channel(self.on_channel_open)
docs: AMQP connection callback.
          Creates input channel.
  
          Args:
              connection: AMQP connection