The CLIENT-SERVER routing id of the message. Requires libzmq >= 4.2 and pyzmq built with draft APIs enabled. .. versionadded:: 17

Start the Authentication Agent thread task

Leave context, socket and event loop upon implicit disposal

select(rlist, wlist, xlist, timeout=None) -> (rlist, wlist, xlist) Return the result of poll as a lists of sockets ready for r/w/exception.

Send a single zmq frame. Returns a Future that resolves when sending is complete. Recommend using send_multipart instead.

Send a single zmq message frame on this socket. This queues the message to be sent by the IO thread at a later time. With f

Send json-serialized version of an object. See zmq.socket.send_json for details.

Send a complete multipart zmq message. Returns a Future that resolves when sending is complete.

Send a Python object as a message using pickle to serialize. See zmq.socket.send_json for details.

Send a unicode message with an encoding. See zmq.socket.send_unicode for details.

send a message every second

set a context option see zmq_ctx_set

Call the given callback when the stream is closed.

Set the High Water Mark. On libzmq ≥ 3, this sets both SNDHWM and RCVHWM .. warning:: New values only take effect for

Set socket options with a unicode object. This is simply a wrapper for setsockopt to protect from encoding ambiguity. See the 0MQ do

Enqueue setsockopt(opt, value) for ctrl_socket See zmq.Socket.setsockopt for details.

Set timeout using SIGALRM Avoids infinite hang in context.term for an unclean context, raising an error instead.

test PLAIN failed authentication

thread for slowly responding to replies.

Decorator for adding a socket to a function. Usage:: @socket(zmq.PUSH) def foo(push): ... .. versionadded:: 15.

Starts the timer.

Return time since start in microseconds

DEPRECATED, does nothing

Return the error string given the error number.

Close or terminate the context. This can be called to close the context by hand. If this is not called, the context will aut

Message above 30 bytes are never copied by 0MQ.

set setting/getting sockopts as attributes

test using a bad object

Test that appropriate errors are raised on bad socket options

test using a buffer as input

test non-copying numpy array messages

receiving buffered output

Test the Frame.bytes property.

Ensure callable check works.

s.close() after ctx.destroy() should be fine