bentools/guzzle-queued

Queues asynchronous requests, handled by workers.

Maintainers

Details

github.com/bpolaszek/guzzle-queued

Source

Issues

Installs: 100

Dependents: 0

Suggesters: 0

Security: 0

Stars: 1

Watchers: 5

Forks: 0

Open Issues: 0

v2.7 2016-10-03 13:09 UTC

Requires

MIT 03ea53564596a0d4db9a76030c1c42f9efb7b274

This package is auto-updated.

Last update: 2024-04-14 23:34:49 UTC

README

This library allows you to send asynchronous requests via Guzzle 6, using a queue system (only Beanstalk supported for the moment).

Installation

composer require bentools/guzzle-queued

Usage

use BenTools\GuzzleQueued\Client as QueuedClient;
use GuzzleHttp\Psr7\Request as PSR7Request;
use Pheanstalk\Pheanstalk;

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

$pheanstalk = new Pheanstalk('127.0.0.1');
$guzzle     = new \GuzzleHttp\Client();
$client     = new QueuedClient($guzzle, $pheanstalk);
$request    = new PSR7Request('GET', 'http://httpbin.org/user-agent');
$promise    = $client->sendAsync($request)->then(function (\Psr\Http\Message\ResponseInterface $response) {
    echo (string) $response->getBody();
});

$promise->wait(); // Now the hard work has to be done by a separate PHP process

Launch as many workers as needed with the following command:

php vendor/bin/guzzle-request-worker.php &

Event Dispatcher

Create your own worker and hook to the following events:

  • \BenTools\GuzzleQueued\JobEvent::BEFORE_PROCESS: before the request is processed
  • \BenTools\GuzzleQueued\JobEvent::AFTER_PROCESS: after the request is processed
  • \BenTools\GuzzleQueued\JobEvent::ERROR: if an error occured

Change response, prevent the request from being effectively sent, delay the request, ...