code: def connection(self):
          
          connection = getattr(self.state, "connection", None)
          if connection is None:
              connection = self.state.connection = pika.BlockingConnection(
                  parameters=self.parameters)
              self.connections.add(connection)
          return connection
docs: The :class:`pika.BlockingConnection` for the current
          thread.  This property may change without notice.