(use zmq srfi-18)

(define wx (make-socket 'sub))
(define vent (make-socket 'pull))

(socket-option-set! wx 'subscribe "60047 ")
(connect-socket wx   "tcp://localhost:5556")
(connect-socket vent "tcp://localhost:5557")

(define items (poll-items (list wx vent) '()))

(let loop ()
  (poll items #t)
  (for-each-poll-item
   items
   (lambda (s)
     (print "received msg: " (receive-message s)))
   identity)
  (thread-sleep! 0.25)  ;; just in case (actually to verify that messages interleave)
  (loop))


#|
received msg: 60047 118 19
received msg: 0
received msg: 74
received msg: 60047 17 51
received msg: 81
received msg: 60047 112 18
received msg: 96
received msg: 83
received msg: 60047 131 29
received msg: 73
received msg: 88
...
|#