Commit 5cdaf8d2 authored by shenshuo's avatar shenshuo

消息队列端口强制转化为int类型

parent 2f1f4d57
...@@ -27,7 +27,7 @@ class MessageQueueBase(object): ...@@ -27,7 +27,7 @@ class MessageQueueBase(object):
if const.MQ_PWD not in mq_config: if const.MQ_PWD not in mq_config:
raise ConfigError(const.MQ_PWD) raise ConfigError(const.MQ_PWD)
self.addr = mq_config[const.MQ_ADDR] self.addr = mq_config[const.MQ_ADDR]
self.port = mq_config[const.MQ_PORT] self.port = int(mq_config[const.MQ_PORT])
self.vhost = mq_config[const.MQ_VHOST] self.vhost = mq_config[const.MQ_VHOST]
self.user = mq_config[const.MQ_USER] self.user = mq_config[const.MQ_USER]
self.pwd = mq_config[const.MQ_PWD] self.pwd = mq_config[const.MQ_PWD]
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment