docs: def producer(self, conn):
          """Get a consumer for a connection."""
          return Producer(
              conn,
              exchange=self.exchange,
              routing_key=self.routing_key,
              auto_declare=True,
          )