code: def create_message(self):
          
          self.counter += 1
          self._transport.send(
              "transient.transaction",
              "TXMessage #%d\n++++++++Produced@ %f"
              % (self.counter, (time.time() % 1000) * 1000),
          )
          self.log.info("Created message %d", self.counter)
docs: Create and send a unique message for this service.