.dev/samples/rabbitmq_thumper/parallel_processing/parallel_rpc.php
<?php
require __DIR__ . '/../_rabbitmq.php';
$start = time();
$client = new Thumper\RpcClient($registry->getConnection());
$client->initClient();
$client->addRequest($argv[1], 'charcount', 'charcount'); //charcount is the request identifier
$client->addRequest(serialize(['min' => 0, 'max' => (int) $argv[2]]), 'random-int', 'random-int'); //random-int is the request identifier
echo "Waiting for replies…\n";
$replies = $client->getReplies();
var_dump($replies);
echo 'Total time: ', time() - $start, "\n";