diff --git a/LCS/Messaging/python/messaging/messagebus.py b/LCS/Messaging/python/messaging/messagebus.py index 638b1cfeb440155912da71434288bb4ccb2ac398..e405e16b0b9b31018d054e5233ca4a6a3998eda6 100644 --- a/LCS/Messaging/python/messaging/messagebus.py +++ b/LCS/Messaging/python/messaging/messagebus.py @@ -102,7 +102,7 @@ class FromBus(object): logger.info('[FromBus] Ignoring duplicate reconnect option in connection init') self.connection = proton.utils.BlockingConnection(self.broker, **self.broker_options) logger.debug("[FromBus] Connected to broker: %s", self.broker) - except proton.utils.ConnectionException as ex: + except proton.ConnectionException as ex: logger.exception('[FromBus] Initialization failed') raise MessageBusError('[FromBus] Initialization failed (%s)' % ex) @@ -362,7 +362,7 @@ class ToBus(object): logger.info('[ToBus] Ignoring duplicate reconnect option in connection init') self.connection = proton.utils.BlockingConnection(self.broker, **self.broker_options) logger.debug("[ToBus] Connected to broker: %s", self.broker) - except proton.utils.ConnectionException as ex: + except proton.ConnectionException as ex: logger.exception('[ToBus] Initialization failed') raise MessageBusError('[ToBus] Initialization failed (%s)' % ex)