.dev/samples/rabbitmq_thumper/rpc/rpc_client.php

Summary

Maintainability
A
0 mins
Test Coverage
<?php

require __DIR__ . '/../_rabbitmq.php';

$client = new Thumper\RpcClient($registry->getConnection());
$client->initClient();
$client->addRequest($argv[1], 'charcount', 'charcount'); //the third parameter is the request identifier
echo "Waiting for replies…\n";
$replies = $client->getReplies();

var_dump($replies);