in mns/mns_client.py [0:0]
def batch_send_message(self, req, resp):
#check parameter
BatchSendMessageValidator.validate(req)
#make request internal
req_inter = RequestInternal(req.method, uri = "/%s/%s/%s" % (URISEC_QUEUE, req.queue_name, URISEC_MESSAGE))
req_inter.data = MessagesEncoder.encode(req.message_list, req.base64encode)
self.build_header(req, req_inter)
#send request
resp_inter = self.http.send_request(req_inter)
#handle result, make response
resp.status = resp_inter.status
resp.header = resp_inter.header
self.check_status(req_inter, resp_inter, resp, BatchSendMessageDecoder)
if resp.error_data == "":
resp.message_list = BatchSendMessageDecoder.decode(resp_inter.data, req_inter.get_req_id())
if self.logger:
self.logger.info("BatchSendMessage RequestId:%s QueueName:%s MessageCount:%s MessageInfo\n%s" % \
(resp.get_requestid(), req.queue_name, len(req.message_list), \
"\n".join(["MessageId:%s MessageBodyMD5:%s" % (msg.message_id, msg.message_body_md5) for msg in resp.message_list])))