-
Notifications
You must be signed in to change notification settings - Fork 119
/
035-capture.phpt
50 lines (38 loc) · 1.29 KB
/
035-capture.phpt
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
--TEST--
Test device capture
--SKIPIF--
<?php require_once(dirname(__FILE__) . '/skipif.inc'); ?>
--FILE--
<?php
require dirname(__FILE__) . '/zeromq_test_helper.inc';
$context = new ZMQContext();
$front = new ZMQSocket($context, ZMQ::SOCKET_PULL);
$front->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