£Á°èZ¨Ä…–K§‚«“ô4“ÒÙ´dîfUÙÃÅ WKbyʦ•êŽ…È®FÒ¿ÊÎóCozá¬S@6{Í:›œêZÌ:Š•_%:¢¾¾~;‘Ã~芩ÊǍí`ÔÑ©ú뙵'5I¿fš×WO%ø9¾«¾DK|€ùÍD”Ýs]nHÕ¶êםӼ㞪éUWŸÈË%DÒÕ¬ï‘]/Åcx ‰ï2ß]ä6G[]S£Ôϯrs{úëóµmÒï#UQxo·õÞCe]"±/aÙ&Eã4ú9Jé_ÞåëdãöKë)AÞ ¯¹ægƒÛowЍø^d™ý½ßB7áyMä9ÜÖUã !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! --TEST-- Test device capture --SKIPIF-- --FILE-- bind (ZEROMQ_TEST_DSN); $sender = new ZMQSocket($context, ZMQ::SOCKET_PUSH); $sender->connect(ZEROMQ_TEST_DSN); $backend = new ZMQSocket($context, ZMQ::SOCKET_PUSH); $backend->bind (ZEROMQ_TEST_DSN2); $receiver = new ZMQSocket($context, ZMQ::SOCKET_PULL); $receiver->connect(ZEROMQ_TEST_DSN2); $capture = new ZMQSocket($context, ZMQ::SOCKET_PUB); $capture->bind ('inproc://capture'); $capture_listener = new ZMQSocket($context, ZMQ::SOCKET_SUB); $capture_listener->connect ('inproc://capture'); $capture_listener->setSockOpt (ZMQ::SOCKOPT_SUBSCRIBE, ""); $device = new ZMQDevice($front, $backend, $capture); $device->setIdleCallback(function () { return false; }, 100, 'ddd'); $sender->sendmsg ("Hello backend"); $device->run (); $device->run (); echo "Receiving from receiver" . PHP_EOL; var_dump($receiver->recvmsg()); echo "Receiving from capture listener" . PHP_EOL; var_dump($capture_listener->recvmsg()); echo "OK"; ?> --EXPECT-- Receiving from receiver string(13) "Hello backend" Receiving from capture listener string(13) "Hello backend" OK