examples/zmq/request_reply/1/receiver.php from SAREhub/PHP_Commons

examples/zmq/request_reply/1/receiver.php

Summary

Maintainability

0 mins

Test Coverage

Issues
Source
Stats

Issues

<?php

use SAREhub\Commons\Misc\Dsn;
use SAREhub\Commons\Zmq\RequestReply\RequestReceiver;

require './ExampleCommons.php';

$receiver = RequestReceiver::inContext(new ZMQContext())
    ->bind(Dsn::tcp()->endpoint('127.0.0.1:30001'));
while (1) {
    logMessage("RECEIVER:");
    $request = $receiver->receiveRequest();
    logMessage("GOT REQUEST: " . $request);
    $receiver->sendReply("reply");
    logMessage("REPLY SENT");
    break;
}

$receiver->unbind();