From 340fdbc7b63292c3e33a58bfc434587db3e22569 Mon Sep 17 00:00:00 2001
From: Stephen Diehl <stephen.m.diehl@gmail.com>
Date: Tue, 13 Mar 2012 11:03:37 -0400
Subject: [PATCH] Added zmq debug console for great good.

---
 zipline/zmq_utils.py | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)
 create mode 100644 zipline/zmq_utils.py

diff --git a/zipline/zmq_utils.py b/zipline/zmq_utils.py
new file mode 100644
index 00000000..e7c09047
--- /dev/null
+++ b/zipline/zmq_utils.py
@@ -0,0 +1,16 @@
+import gevent
+from gevent_zeromq import zmq
+
+def ZmqConsole(sock_typ, socket_addr, sock_conn=None, context=None):
+
+    context = context or zmq.Context.instance()
+    socket = context.socket(zmq.PULL)
+    socket.connect('tcp://127.0.0.1:3141')
+
+    def console():
+        while True:
+            msg = socket.recv()
+            print msg
+            import pdb; pdb.set_trace()
+
+    return gevent.spawn(console)