code: def lease(self):
          
          self._request_queue.put(
              requests.LeaseRequest(ack_id=self._ack_id, byte_size=self.size)
          )
docs: Inform the policy to lease this message continually.
  
          .. note::
              This method is called by the constructor, and you should never
              need to call it manually.