zenon/dse-assignment
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

small refactorings

Browse Source
This commit is contained in:
Marco Zeisler 2021-05-24 17:54:38 +02:00
parent bac2c079f0
commit aaa4390c1d
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
components/shared/message_broker_wrapper.py
View File

@ -56,7 +56,7 @@ class MBWrapper:
if type(message) is not bytes: if type(message) is not bytes:
message = str(message).encode() message = str(message).encode()
self._channel.basic_publish(exchange=self.exchange_name, routing_key='', body=message) self._channel.basic_publish(exchange=self.exchange_name, routing_key='', body=message)
self.print(" [x] Sent %r" % message) self.print("[{}] Sent {}".format(self.exchange_name, message))
def close(self): def close(self):
self._connection.close() self._connection.close()