Merge pull request #1 from sn6uv/master

fixes relating to pyzmq changes, updated to work at least with pyzmq 13.1
fperez · Jun 9, 2016 · 4ee815b · 4ee815b
2 parents 88b7084 + ab391a1
commit 4ee815b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/frontend.py b/frontend.py
@@ -177,7 +177,7 @@ def main():
 
     # Create initial sockets
     c = zmq.Context()
-    request_socket = c.socket(zmq.XREQ)
+    request_socket = c.socket(zmq.DEALER)
     request_socket.connect(req_conn)
 
     sub_socket = c.socket(zmq.SUB)

diff --git a/kernel.py b/kernel.py
@@ -216,7 +216,7 @@ def complete(self, msg):
     def start(self):
         while True:
             ident = self.reply_socket.recv()
-            assert self.reply_socket.rcvmore(), "Unexpected missing message part."
+            assert self.reply_socket.rcvmore, "Unexpected missing message part."
             msg = self.reply_socket.recv_json()
             omsg = Message(msg)
             print>>sys.__stdout__, omsg
@@ -241,7 +241,7 @@ def main():
 
     session = Session(username=u'kernel')
 
-    reply_socket = c.socket(zmq.XREP)
+    reply_socket = c.socket(zmq.ROUTER)
     reply_socket.bind(rep_conn)
 
     pub_socket = c.socket(zmq.PUB)