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}