code: def _on_client_ready(self):
          
          _legacy_twisted_log.msg("Successfully connected to the AMQP broker.")
          yield self.client.resumeProducing()
  
          yield self.client.declare_exchanges(self.exchanges)
          yield self.client.declare_queues(self.queues)
          yield self.client.bind_queues(self.bindings)
          for queue, callback in self.consumers.items():
              yield self.client.consume(callback, queue)
  
          _legacy_twisted_log.msg("Successfully declared all AMQP objects.")
          self._client_ready.callback(None)
docs: Called when the client is ready to send and receive messages.