in mns/mns_client.py [0:0]
def get_topic_attributes(self, req, resp):
#check parameter
GetTopicAttrValidator.validate(req)
#make request internal
req_inter = RequestInternal(req.method, "/%s/%s" % (URISEC_TOPIC, req.topic_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 == "":
topic_attr = GetTopicAttrDecoder.decode(resp_inter.data, req_inter.get_req_id())
resp.message_count = int(topic_attr["MessageCount"])
resp.create_time = int(topic_attr["CreateTime"])
resp.last_modify_time = int(topic_attr["LastModifyTime"])
resp.maximum_message_size = int(topic_attr["MaximumMessageSize"])
resp.message_retention_period = int(topic_attr["MessageRetentionPeriod"])
resp.topic_name = topic_attr["TopicName"]
resp.logging_enabled = True if topic_attr["LoggingEnabled"].lower() == "true" else False
if self.logger:
self.logger.info("GetTopicAttributes RequestId:%s TopicName:%s" % (resp.get_requestid(), req.topic_name))