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;
}