search

bartongroup / slivka

http://bartongroup.github.io/slivka/
Apache License 2.0
7 stars 3 forks source link

When slivka-queue is not available, the client waits indefinitely. #70

Closed warownia1 closed 4 years ago

warownia1 commented 4 years ago

ZMQ socket communicating with the local queue should timeout (raise an exception) if no reply is received.

warownia1 commented 4 years ago

See: http://api.zeromq.org/4-1:zmq-setsockopt set ZMQ_REQ_RELAXED to 1 to allow repeated send see also ZMQ_REQ_CORRELATE The timeout can be set using socket.setsockopt(zmq.RCVTIMEO, timeout) which causes zmq.Again exception on timeout.