code: def initializing(self):
          
          self.subid = self._transport.subscribe(
              "transient.transaction", self.receive_message, acknowledgement=True
          )
docs: Subscribe to a channel. Received messages must be acknowledged.