in mns/mns_client.py [0:0]
def create_topic(self, req, resp):
#check parameter
CreateTopicValidator.validate(req)
#make request internal
req_inter = RequestInternal(req.method, "/%s/%s" % (URISEC_TOPIC, req.topic_name))
req_inter.data = TopicEncoder.encode(req)
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 == "":
resp.topic_url = self.lower_header(resp.header)["location"]
if self.logger:
self.logger.info("CreateTopic RequestId:%s TopicName:%s TopicURl:%s" % \
(resp.get_requestid(), req.topic_name, resp.topic_url))