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.

def enqueue_message(self, message, timeout):
    """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.
    """
    # 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)