diff --git a/LCS/MessageBus/src/MsgBus.py b/LCS/MessageBus/src/MsgBus.py index a40c88b78752135b4e657e6ffb4d6d3492180e12..d0787e400b885136f5d224f660f2e38f7e89171f 100644 --- a/LCS/MessageBus/src/MsgBus.py +++ b/LCS/MessageBus/src/MsgBus.py @@ -23,7 +23,7 @@ from qpid.messaging import * broker="localhost" options="create:always, node: { type: queue, durable: True}" -class ToBus(): +class ToBus: def __init__(self, address, options=options, broker=broker): self.connection = Connection(broker) self.connection.reconnect = True @@ -47,7 +47,7 @@ class ToBus(): def sendmsg(self,msg): self.sender.send(msg) -class FromBus(): +class FromBus: def __init__(self, address, options=options, broker=broker): self.connection = Connection(broker) self.connection.reconnect = True