Show More
@@ -32,22 +32,22 b' class InvalidPortNumber(Exception):' | |||||
32 | def make_shell_socket(context, identity, address): |
|
32 | def make_shell_socket(context, identity, address): | |
33 | socket = context.socket(zmq.DEALER) |
|
33 | socket = context.socket(zmq.DEALER) | |
34 | socket.linger = 1000 |
|
34 | socket.linger = 1000 | |
35 |
socket. |
|
35 | socket.identity = identity | |
36 | socket.connect(address) |
|
36 | socket.connect(address) | |
37 | return socket |
|
37 | return socket | |
38 |
|
38 | |||
39 | def make_iopub_socket(context, identity, address): |
|
39 | def make_iopub_socket(context, identity, address): | |
40 | socket = context.socket(zmq.SUB) |
|
40 | socket = context.socket(zmq.SUB) | |
41 | socket.linger = 1000 |
|
41 | socket.linger = 1000 | |
42 | socket.setsockopt(zmq.SUBSCRIBE,b'') |
|
42 | socket.subscribe = b'' | |
43 |
socket. |
|
43 | socket.identity = identity | |
44 | socket.connect(address) |
|
44 | socket.connect(address) | |
45 | return socket |
|
45 | return socket | |
46 |
|
46 | |||
47 | def make_stdin_socket(context, identity, address): |
|
47 | def make_stdin_socket(context, identity, address): | |
48 | socket = context.socket(zmq.DEALER) |
|
48 | socket = context.socket(zmq.DEALER) | |
49 | socket.linger = 1000 |
|
49 | socket.linger = 1000 | |
50 |
socket. |
|
50 | socket.identity = identity | |
51 | socket.connect(address) |
|
51 | socket.connect(address) | |
52 | return socket |
|
52 | return socket | |
53 |
|
53 |
General Comments 0
You need to be logged in to leave comments.
Login now