Untested: response_queue (formerly output_queue) now expects a JSON object which...

diff --git a/stratum.py b/stratum.py
index d0fd61e..74e5866 100644 (file)
--- a/stratum.py
+++ b/stratum.py
@@ -88,12 +88,13 @@ class TcpClientResponder(threading.Thread):
     def run(self):
         while not self.shared.stopped() or self.session.stopped():
             response = self.session.pop_response()
+            raw_response = json.dumps(response)
             # Possible race condition here by having session
             # close connection?
             # I assume Python connections are thread safe interfaces
             connection = self.session.connection()
             try:
-                connection.send(response + "\n")
+                connection.send(raw_response + "\n")
             except:
                 self.session.stop()