diff --git a/usrreg_mq.py b/usrreg_mq.py
index 11ad99dd376821238df722e0d6c3945ba726b554..fea2dffde1cb8e22f09e4eda86e3bd80d420cca0 100644
--- a/usrreg_mq.py
+++ b/usrreg_mq.py
@@ -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()