code: def enqueue_message(self, message, timeout):
      
      # Ack WRTE messages immediately, handle our OPEN ack if it gets enqueued.
      if message.command == 'WRTE':
        self._send_command('OKAY', timeout=timeout)
      elif message.command == 'OKAY':
        self._set_or_check_remote_id(message.arg0)
      self.message_queue.put(message)
docs: Add the given message to this transport's queue.
  
      This method also handles ACKing any WRTE messages.
  
      Args:
        message: The AdbMessage to enqueue.
        timeout: The timeout to use for the operation.  Specifically, WRTE
          messages cause an OKAY to be sent; timeout is used for that send.