diff options
author | 2018-05-26 16:37:56 +0200 | |
---|---|---|
committer | 2018-05-26 16:37:56 +0200 | |
commit | 1f4b827b439e236a24a811404dcb5c2e278f206d (patch) | |
tree | 4fa1251fe338a38dc3f955fa7783cac497b563ca /snekweb.py | |
parent | automatically clean up queues and message to reduce rabbitmq memory footprint (diff) |
add rabbitmq mgmt webinterface, handle container autodiscovery better, minor code optimisations, update readme
Diffstat (limited to 'snekweb.py')
-rw-r--r-- | snekweb.py | 7 |
1 files changed, 5 insertions, 2 deletions
@@ -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() |