From 3314b933240958f3d01e7c8ee5764dd3b690d789 Mon Sep 17 00:00:00 2001 From: Christopher Baklid Date: Sat, 26 May 2018 14:15:11 +0200 Subject: automatically clean up queues and message to reduce rabbitmq memory footprint --- snekweb.py | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) (limited to 'snekweb.py') diff --git a/snekweb.py b/snekweb.py index 8929438..d7ed0d2 100644 --- a/snekweb.py +++ b/snekweb.py @@ -1,10 +1,7 @@ import traceback -import queue import threading -import time -import json import logging -import geventwebsocket +import json from flask import Flask from flask import render_template @@ -55,7 +52,7 @@ def websocket_route(ws, snekboxid): message = ws.receive() if message: snek_msg = json.dumps({snekboxid: message}) - log.info(f"forwarding {snek_msg} to rabbitmq") + log.info(f"User {snekboxid} sends message\n{message.strip()}") rmq.publish(snek_msg) except Exception: -- cgit v1.2.3