fei/api-client

Client side API helpers

Api Client

, _(*1)

Low level API client., _(*2)

All API client should use this library and extend \Fei\ApiClient\AbstractApiClient abstract class., _(*3)

Installation

Use Composer: composer.phar require fei/mailer-client, _(*4)

Or add this requirement "fei/api-client": "^1.1.0" to your composer.json file., _(*5)

Use the BeanstalkProxyWorker

The BeanstalkProxyWorker is used for consume Beanstalkd messages queue and send them to the targeted api server., _(*6)

<?php

require __DIR__ . '/vendor/autoload.php';

use Fei\ApiClient\Transport\BasicTransport;
use Fei\ApiClient\Worker\BeanstalkProxyWorker;
use Pheanstalk\Pheanstalk;
use Pheanstalk\PheanstalkInterface;

$host = "127.0.0.1";
$port = PheanstalkInterface::DEFAULT_PORT;

$worker = new BeanstalkProxyWorker();
$worker->setPheanstalk(new Pheanstalk($host, $port));
$worker->setTransport(new BasicTransport());

$worker->run(BeanstalkProxyWorker::VERBOSE);

This example will consume one message from Beanstakld tube (or queue) and send it to the api server., _(*7)

For handle more messages you should create a infinite loop !, _(*8)

<?php

require __DIR__ . '/vendor/autoload.php';

use Fei\ApiClient\Transport\BasicTransport;
use Fei\ApiClient\Worker\BeanstalkProxyWorker;
use Pheanstalk\Pheanstalk;
use Pheanstalk\PheanstalkInterface;

$host = "127.0.0.1";
$port = PheanstalkInterface::DEFAULT_PORT;

$worker = new BeanstalkProxyWorker();
$worker->setPheanstalk(new Pheanstalk($host, $port));
$worker->setTransport(new BasicTransport());

while (true) {
    $worker->run(BeanstalkProxyWorker::VERBOSE);
}

For a reliable worker, please use script/api-client-worker.php:, _(*9)

api-client-worker.php -h 127.0.0.1 -p 11300 -d 5