rpc-server

#!/usr/bin/env php
<?php
/**
 * Initialize the logger and AMQP connection.
 */
require __DIR__ . '/common.php';

/**
 * Create an Overpass RPC server that exposes a single procedure named 'double'
 * which takes a single number as input and doubles it.
 */
$server = new Icecave\Overpass\Amqp\Rpc\AmqpRpcServer(
    $logger,
    $amqpChannel
);

$server->expose(
    'double',
    function ($value) {
        return $value * 2;
    }
);

pcntl_signal(
    SIGINT,
    function() use ($server) {
        $server->stop();
    }
);

/**
 * Service RPC requests forever!
 */
$server->run();