1<?php 2 3define('ZEROMQ_TEST_DSN', 'inproc://php-test'); 4define('ZEROMQ_TEST_DSN2', 'inproc://php-test-second'); 5 6function create_server($persistent_id = null) 7{ 8 $context = new ZMQContext(); 9 $server = $context->getSocket(ZMQ::SOCKET_REP, $persistent_id) 10 ->bind(ZEROMQ_TEST_DSN); 11 return $server; 12} 13 14function create_client($persistent_id = null) 15{ 16 $context = new ZMQContext(); 17 $client = $context->getSocket(ZMQ::SOCKET_REQ, $persistent_id) 18 ->connect(ZEROMQ_TEST_DSN); 19 20 return $client; 21} 22 23function bind_callback(ZMQSocket $socket, $persistent_id = null) 24{ 25 static $port = 5566; 26 27 $socket->bind(ZEROMQ_TEST_DSN . "-{$port}"); 28 $port++; 29}