private Message parseMessage()

in src/main/java/com/aliyun/mns/model/serialize/queue/MessageListDeserializer.java [71:136]


    private Message parseMessage(Element root) {
        Message message = new Message();

        String messageId = safeGetElementContent(root, MESSAGE_ID_TAG, null);
        if (messageId == null) {
            message.setErrorMessage(parseErrorMessageResult(root));
            return message;
        }

        message.setMessageId(messageId);
        String messageBody = safeGetElementContent(root, MESSAGE_BODY_TAG, null);
        if (messageBody != null) {
            // try {
            message.setMessageBody(messageBody, Message.MessageBodyType.RAW_STRING);
            // } catch (UnsupportedEncodingException e) {
            // throw new RuntimeException("Not support enconding:"
            // + DEFAULT_CHARSET);
            // }
        }

        String messageBodyMD5 = safeGetElementContent(root,
            MESSAGE_BODY_MD5_TAG, null);
        message.setMessageBodyMD5(messageBodyMD5);

        String receiptHandle = safeGetElementContent(root, RECEIPT_HANDLE_TAG,
            null);
        message.setReceiptHandle(receiptHandle);

        String enqueTime = safeGetElementContent(root, ENQUEUE_TIME_TAG, null);
        if (enqueTime != null) {
            message.setEnqueueTime(new Date(Long.parseLong(enqueTime)));
        }

        String nextVisibleTime = safeGetElementContent(root,
            NEXT_VISIBLE_TIME_TAG, null);
        if (nextVisibleTime != null) {
            message.setNextVisibleTime(new Date(Long.parseLong(nextVisibleTime)));
        }

        String firstDequeueTime = safeGetElementContent(root,
            FIRST_DEQUEUE_TIME_TAG, null);
        if (firstDequeueTime != null) {
            message.setFirstDequeueTime(new Date(
                Long.parseLong(firstDequeueTime)));
        }

        String dequeueCount = safeGetElementContent(root, DEQUEUE_COUNT_TAG,
            null);
        if (dequeueCount != null) {
            message.setDequeueCount(Integer.parseInt(dequeueCount));
        }

        String priority = safeGetElementContent(root, PRIORITY_TAG,
            null);
        if (priority != null) {
            message.setPriority(Integer.parseInt(priority));
        }

        // 解析 userProperties
        safeAddPropertiesToMessage(root, message);

        // 解析 systemProperties
        safeAddSystemPropertiesToMessage(root, message);

        return message;
    }