Wallogit.com
2017 © Pedro Peláez
LIFO Queue with ZeroMQ
, (*1)
ZeroMQ LIFO Queue, (*2)
usage examples:, (*3)
Client:, (*4)
<?php
include __DIR__ . '/../vendor/autoload.php';
use Zmqlifo\Client;
$queue = Client::factory('tcp://127.0.0.1:4444');
echo $queue->run("ls -latr")->getOutput();
echo $queue->run("pwd")->getOutput();
Server, (*5)
<?php
include __DIR__ . '/../vendor/autoload.php';
use Symfony\Component\Process\Process;
use Zmqlifo\Server;
$server = Server::factory('tcp://127.0.0.1:4444');
$server->registerOnMessageCallback(function ($msg) {
$process = new Process($msg);
$process->setTimeout(3600);
$process->run();
return $process->getOutput();
});
$server->run();
LIFO Queue with ZeroMQ
MIT
console cli process zeromq zmq