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