ZMQ Pipeline vanilla push

test_push.php

<?php

$zmq = new ZMQContext(1);
$socket = $zmq->getSocket(ZMQ::SOCKET_PUSH, 'xyz');
$socket->connect('ipc:///tmp/xyz');

while (true) {

                $msgs = rand(1, 300);
                for ($n=0; $n<$msgs; $n++) {
                        echo "+";
                        $socket->send(json_encode('bogus-' . $n));
                }

                usleep(rand(0, 1000000));
}