sibirsky87/rmqrpc

RabbitMQ RPC module

dev-master 2015-09-22 08:01 UTC

Requires

• videlalvaro/php-amqplib: 2.5.*

BSD-3-Clause

• anton.baikov

• rabbitmq
• apqp

README

Example:

require_once DIR . '/vendor/autoload.php';

use Sibirsky87\Rmqrpc\AbstractRpcModel;

class RpcServer extends AbstractRpcModel {

protected $queue = 'rpc_queue';

public function getResult($message)
{
    return  " response to " . print_r($message, TRUE);
}

}

$config = [ 'host' => "127.0.0.1", 'port' => 5672, 'user' => 'guest', 'password' => 'guest', 'target' => 1 ]; $server = new RpcServer($config); $server->process();