Skip to content
Snippets Groups Projects
Commit d8656de8 authored by Bo-Chun Chen's avatar Bo-Chun Chen
Browse files

Remove unnecessary lines

parent fc2b0ca1
No related branches found
No related tags found
2 merge requests!23Feat resolve uid gid,!9Feat connection module
......@@ -46,10 +46,6 @@ class UserRegMQ(object):
self._connection.close()
def publish_msg(self, obj):
if self._channel is None or not self._channel.is_open:
return
# Establish connection to RabbitMQ server
self.connect()
self._channel.basic_publish(exchange=self.EXCHANGE, routing_key=obj['routing_key'], body=json.dumps(obj['msg']))
self.disconnect()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment