automatically clean up queues and message to reduce rabbitmq memory footprint

1 files changed, 2 insertions, 5 deletions

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: