code: def resumeProducing(self):
          
          # Start consuming
          self._running = True
          for consumer in self._consumers.values():
              queue_object, _ = yield consumer.channel.basic_consume(
                  queue=consumer.queue, consumer_tag=consumer.tag
              )
              deferred = self._read(queue_object, consumer)
              deferred.addErrback(
                  lambda f: _legacy_twisted_log.msg,
                  "_read failed on consumer {c}",
                  c=consumer,
                  logLevel=logging.ERROR,
              )
          _legacy_twisted_log.msg("AMQP connection successfully established")
docs: Starts or resumes the retrieval of messages from the server queue.
  
          This method starts receiving messages from the server, they will be
          passed to the consumer callback.
  
          .. note:: This is called automatically when :meth:`.consume` is called,
              so users should not need to call this unless :meth:`.pauseProducing`
              has been called.
  
          Returns:
              defer.Deferred: fired when the production is ready to start