Skip to content
This repository was archived by the owner on Feb 14, 2024. It is now read-only.

Commit b391bac

Browse files
author
Trevor Bernard
committed
Add dealer-router test
1 parent 7277449 commit b391bac

File tree

1 file changed

+15
-0
lines changed

1 file changed

+15
-0
lines changed

test/zeromq/zmq_test.clj

+15
Original file line numberDiff line numberDiff line change
@@ -21,3 +21,18 @@
2121
(zmq/bind "tcp://*:12310"))]
2222
(let [actual (zmq/receive-str pull)]
2323
(is (= nil actual)))))
24+
25+
26+
(deftest dealer-router-test
27+
(with-open [dealer (doto (zmq/socket context :dealer)
28+
(zmq/set-receive-timeout 3000)
29+
(zmq/bind "tcp://*:12350"))
30+
router (doto (zmq/socket context :router)
31+
(zmq/connect "tcp://127.0.0.1:12350"))]
32+
(s/send "myid" dealer zmq/send-more)
33+
(s/send "payload" dealer 0)
34+
(let [[id & _] (zmq/receive-all router)]
35+
(zmq/send router id zmq/send-more)
36+
(zmq/send-str router "ack")
37+
(let [actual (zmq/receive-str dealer)]
38+
(is (= "ack" actual))))))

0 commit comments

Comments
 (0)