From 1f4b827b439e236a24a811404dcb5c2e278f206d Mon Sep 17 00:00:00 2001 From: Christopher Baklid Date: Sat, 26 May 2018 16:37:56 +0200 Subject: add rabbitmq mgmt webinterface, handle container autodiscovery better, minor code optimisations, update readme --- snekweb.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) (limited to 'snekweb.py') 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() -- cgit v1.2.3