Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import zmq
- context = zmq.Context()
- sa = context.socket(zmq.ROUTER)
- sa.setsockopt(zmq.IDENTITY, b"A")
- sa.setsockopt(zmq.SNDTIMEO, 0)
- sa.bind("tcp://127.0.0.1:43292")
- sa.send_multipart([b"NON-EXISTENT", b"Message"], flags=zmq.NOBLOCK)
- # Shouldn't this raise an zmq.EAGAIN exception?
Advertisement
Add Comment
Please, Sign In to add comment