in mns/mns_xml_handler.py [0:0]
def decode(xml_data, base64decode, req_id=None):
data_listofdic = []
message_list = []
DecoderBase.xml_to_listofdic("Messages", "Message", xml_data, data_listofdic, req_id)
try:
for data_dic in data_listofdic:
msg = PeekMessageResponseEntry()
if base64decode:
msg.message_body = base64.b64decode(data_dic["MessageBody"])
else:
msg.message_body = data_dic["MessageBody"]
msg.dequeue_count = int(data_dic["DequeueCount"])
msg.enqueue_time = int(data_dic["EnqueueTime"])
msg.first_dequeue_time = int(data_dic["FirstDequeueTime"])
msg.message_id = data_dic["MessageId"]
msg.message_body_md5 = data_dic["MessageBodyMD5"]
msg.priority = int(data_dic["Priority"])
message_list.append(msg)
except Exception as err:
raise MNSClientNetworkException("RespDataDamaged", xml_data, req_id)
return message_list