aboutsummaryrefslogtreecommitdiffstats
path: root/snekweb.py
diff options
context:
space:
mode:
Diffstat (limited to 'snekweb.py')
-rw-r--r--snekweb.py7
1 files changed, 5 insertions, 2 deletions
diff --git a/snekweb.py b/snekweb.py
index d7ed0d2..2c0bb91 100644
--- a/snekweb.py
+++ b/snekweb.py
@@ -36,14 +36,17 @@ def websocket_route(ws, snekboxid):
def message_handler(ch, method, properties, body, thread_ws):
msg = body.decode('utf-8')
- log.debug(f"message_handler: {msg}")
thread_ws.send(msg)
ch.basic_ack(delivery_tag=method.delivery_tag)
consumer_parameters = {'queue': snekboxid,
'callback': message_handler,
'thread_ws': localdata.thread_ws}
- consumer = threading.Thread(target=rmq.consume, kwargs=consumer_parameters)
+
+ consumer = threading.Thread(
+ target=rmq.consume,
+ kwargs=consumer_parameters)
+
consumer.daemon = True
consumer.start()