From aeecf19f77536750aacb109c14a30182873bfbf5 Mon Sep 17 00:00:00 2001 From: fawce Date: Tue, 14 Feb 2012 13:52:10 -0500 Subject: [PATCH] switched to gevent zmq, fixed hangups --- zipline/core.py | 2 +- zipline/messaging.py | 2 +- zipline/sources.py | 2 +- zipline/test/client.py | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/zipline/core.py b/zipline/core.py index 7e9b9339..430bb002 100644 --- a/zipline/core.py +++ b/zipline/core.py @@ -2,7 +2,7 @@ Provides simulated data feed services... """ import multiprocessing -import zmq +from gevent_zeromq import zmq import json import copy import threading diff --git a/zipline/messaging.py b/zipline/messaging.py index db36f219..638a2fdf 100644 --- a/zipline/messaging.py +++ b/zipline/messaging.py @@ -3,7 +3,7 @@ Commonly used messaging components. """ import json import uuid -import zmq +from gevent_zeromq import zmq import zipline.util as qutil diff --git a/zipline/sources.py b/zipline/sources.py index b844855d..e1ffb13c 100644 --- a/zipline/sources.py +++ b/zipline/sources.py @@ -2,7 +2,7 @@ Provides data handlers that can push messages to a zipline.core.DataFeed """ import datetime -import zmq +from gevent_zeromq import zmq import json import random diff --git a/zipline/test/client.py b/zipline/test/client.py index 0f4bc80a..0cb7ffa2 100644 --- a/zipline/test/client.py +++ b/zipline/test/client.py @@ -1,4 +1,4 @@ -import zmq +from gevent_zeromq import zmq import json import zipline.util as qutil