in mns/mns_client.py [0:0]
def receive_message(self, req, resp):
#check parameter
ReceiveMessageValidator.validate(req)
#make request internal
req_url = "/%s/%s/%s" % (URISEC_QUEUE, req.queue_name, URISEC_MESSAGE)
if req.wait_seconds != -1:
req_url += "?waitseconds=%s" % req.wait_seconds
req_inter = RequestInternal(req.method, req_url)
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)
if resp.error_data == "":
data = RecvMessageDecoder.decode(resp_inter.data, req.base64decode, req_inter.get_req_id())
self.make_recvresp(data, resp)
if self.logger:
self.logger.info("ReceiveMessage RequestId:%s QueueName:%s WaitSeconds:%s MessageId:%s MessageBodyMD5:%s NextVisibilityTime:%s ReceiptHandle:%s EnqueueTime:%s DequeueCount:%s" % \
(resp.get_requestid(), req.queue_name, req.wait_seconds, resp.message_id, \
resp.message_body_md5, resp.next_visible_time, resp.receipt_handle, resp.enqueue_time, resp.dequeue_count))