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:01 +02:00
parent 725580675a
commit bac2c079f0
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
components/shared/message_broker_wrapper.py
View File

@ -43,7 +43,7 @@ class MBWrapper:
self._channel.queue_bind(exchange=self.exchange_name, queue=queue_name) self._channel.queue_bind(exchange=self.exchange_name, queue=queue_name)
self.print(' [*] Waiting for messages. To exit press CTRL+C') self.print('[{}] Waiting for messages.'.format(self.exchange_name))
self._channel.basic_consume( self._channel.basic_consume(
queue=queue_name, on_message_callback=self._receive, auto_ack=True) queue=queue_name, on_message_callback=self._receive, auto_ack=True)
@ -52,7 +52,7 @@ class MBWrapper:
Thread(target=consumer).start() Thread(target=consumer).start()
def send(self, message: bytes = b"info: Hello World!"): def send(self, message: bytes):
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)