def get_queue_attributes()

in mns/mns_client.py [0:0]

• 24 lines of code
• 4 McCabe index (conditional complexity)

    def get_queue_attributes(self, req, resp):
        #check parameter
        GetQueueAttrValidator.validate(req)

        #make request internal
        req_inter = RequestInternal(req.method, "/%s/%s" % (URISEC_QUEUE, req.queue_name))
        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 == "":
            queue_attr = GetQueueAttrDecoder.decode(resp_inter.data, req_inter.get_req_id())
            resp.active_messages = int(queue_attr["ActiveMessages"])
            resp.create_time = int(queue_attr["CreateTime"])
            resp.delay_messages = int(queue_attr["DelayMessages"])
            resp.delay_seconds = int(queue_attr["DelaySeconds"])
            resp.inactive_messages = int(queue_attr["InactiveMessages"])
            resp.last_modify_time = int(queue_attr["LastModifyTime"])
            resp.maximum_message_size = int(queue_attr["MaximumMessageSize"])
            resp.message_retention_period = int(queue_attr["MessageRetentionPeriod"])
            resp.queue_name = queue_attr["QueueName"]
            resp.visibility_timeout = int(queue_attr["VisibilityTimeout"])
            resp.polling_wait_seconds = int(queue_attr["PollingWaitSeconds"])
            resp.logging_enabled = True if queue_attr["LoggingEnabled"].lower() == "true" else False
            if self.logger:
                self.logger.info("GetQueueAttributes RequestId:%s QueueName:%s" % (resp.get_requestid(), req.queue_name))