2017 © Pedro Peláez
 

library amqp

AMQP implementation based on PECL extension

image

puzzle/amqp

AMQP implementation based on PECL extension

  • Tuesday, October 17, 2017
  • by nlenardou
  • Repository
  • 4 Watchers
  • 2 Stars
  • 11,053 Installations
  • PHP
  • 0 Dependents
  • 0 Suggesters
  • 3 Forks
  • 5 Open issues
  • 17 Versions
  • 13 % Grown

The README.md

Puzzle AMQP PHP >= 8.0

PHP 5.6 & 7.x users, please use < 5.x versions., (*1)

QA

Service Result
CI (PHP 8.3 .. 8.4) CI
Packagist Latest Stable Version Total Downloads

Configuration

# amqp.yml
broker:
    host: myRabbit
    port: 5672
    login: guest
    password: guest
    vhost: /
global:
    disallowSilentDropping: false

# app.yml
id: myApp

Usage

Sending a message

<?php

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

use Puzzle\Configuration\Memory;
use Puzzle\AMQP\Clients\Pecl;
use Puzzle\AMQP\Messages\Message;

$configuration = new Memory(array(
    'amqp/broker/host' => 'myRabbit',
    'amqp/broker/login' => 'guest',
    'amqp/broker/password' => 'guest',
    'amqp/broker/vhost' => '/',
    'app/id' => 'myApp',
));

$client = new Pecl($configuration);

$message = new Message('my.routing.key');
$message->setJson([
    'key' => 'value',
    'key2' => 'value2',
]);

$client->publish('myExchange', $message);

Consuming a message

Worker declaration :

<?php

use Puzzle\AMQP\Consumers;
use Puzzle\AMQP\Clients;
use Puzzle\AMQP\Workers\ProcessorInterfaceAdapter;
use Puzzle\Configuration\Memory;

$configuration = new Memory(array(
    'amqp/broker/host' => 'rabbitmq',
    'amqp/broker/login' => 'guest',
    'amqp/broker/password' => 'guest',
    'amqp/broker/vhost' => '/',
    'app/id' => 'myApp',
));

$consumer = new Consumers\Simple();

$worker = new ExampleWorker();

$consumer->consume(
    new ProcessorInterfaceAdapter($worker),
    new Clients\Pecl($configuration),
    'queue.name'
);

Worker example :

<?php

use Psr\Log\LoggerAwareTrait;
use Psr\Log\NullLogger;
use Puzzle\AMQP\ReadableMessage;
use Puzzle\AMQP\Workers\Worker;

class ExampleWorker implements Worker
{
    use LoggerAwareTrait;

    public function __construct()
    {
        $this->logger = new NullLogger();
    }

    public function process(ReadableMessage $message): void
    {
        // your code here
    }
}

BC Breaks changelog

4.x -> 5.x, (*2)

  • Drop support for php 5.6 & 7.x
  • Worker now catch Throwable, not only Exceptions
    • Consumer / Worker / WorkerContext signature change

3.x -> 4.x, (*3)

  • Chunk management introduced in 3.1 has been refactored and made easier : just use Streamed* bodies and same client as usual

2.x -> 3.x, (*4)

  • Message hooks has been removed
  • Raw & Json implementations of WritableMessage has been replaced by Message + implementations of Body (Text, Json, Binary)
  • Message interface has been renamed into MessageMetadata
  • Some specific features removed from WorkerContext
  • Getter for specific headers removed from MessageAdapter
  • Message InMemory implementation (for unit testing purpose) has been changed
  • MessageAdapter must not be directly constructed anymore, use MessageAdapterFactory instead

1.x -> 2.x, (*5)

  • Drop support for Silex 1.x (in favor of Silex 2.x)

The Versions

17/10 2017

dev-master

9999999-dev

AMQP implementation based on PECL extension

  Sources   Download

MIT

The Requires

 

The Development Requires

by Nicolas Le Nardou

asynchronous amqp

17/10 2017

4.0.0

4.0.0.0

AMQP implementation based on PECL extension

  Sources   Download

MIT

The Requires

 

The Development Requires

by Nicolas Le Nardou

asynchronous amqp

22/09 2017

3.1.1

3.1.1.0

AMQP implementation based on PECL extension

  Sources   Download

MIT

The Requires

 

The Development Requires

by Nicolas Le Nardou

asynchronous amqp

22/09 2017

3.1.0

3.1.0.0

AMQP implementation based on PECL extension

  Sources   Download

MIT

The Requires

 

The Development Requires

by Nicolas Le Nardou

asynchronous amqp

22/09 2017

dev-chunk-3.1

dev-chunk-3.1

AMQP implementation based on PECL extension

  Sources   Download

MIT

The Requires

 

The Development Requires

by Nicolas Le Nardou

asynchronous amqp

22/09 2017

dev-chunk

dev-chunk

AMQP implementation based on PECL extension

  Sources   Download

MIT

The Requires

 

The Development Requires

by Nicolas Le Nardou

asynchronous amqp

10/05 2017

3.0.0

3.0.0.0

AMQP implementation based on PECL extension

  Sources   Download

MIT

The Requires

 

The Development Requires

by Nicolas Le Nardou

asynchronous amqp

24/04 2017

dev-34-transport-content-type

dev-34-transport-content-type

AMQP implementation based on PECL extension

  Sources   Download

MIT

The Requires

 

The Development Requires

by Nicolas Le Nardou

asynchronous amqp

02/04 2017

dev-zip

dev-zip

AMQP implementation based on PECL extension

  Sources   Download

MIT

The Requires

 

The Development Requires

by Nicolas Le Nardou

asynchronous amqp

09/03 2017

dev-missing-tests

dev-missing-tests

AMQP implementation based on PECL extension

  Sources   Download

The Requires

 

The Development Requires

by Nicolas Le Nardou

asynchronous aqmp

09/03 2017

dev-dev

dev-dev

AMQP implementation based on PECL extension

  Sources   Download

The Requires

 

The Development Requires

by Nicolas Le Nardou

asynchronous aqmp

07/03 2017

2.0.0

2.0.0.0

AMQP implementation based on PECL extension

  Sources   Download

The Requires

 

The Development Requires

by Nicolas Le Nardou

asynchronous aqmp

01/03 2017

1.0.4

1.0.4.0

AMQP implementation based on PECL extension

  Sources   Download

The Requires

 

The Development Requires

by Nicolas Le Nardou

asynchronous aqmp

07/04 2016

1.0.3

1.0.3.0

AMQP implementation based on PECL extension

  Sources   Download

The Requires

 

The Development Requires

by Nicolas Le Nardou

asynchronous aqmp

07/04 2016

1.0.2

1.0.2.0

AMQP implementation based on PECL extension

  Sources   Download

The Requires

 

The Development Requires

by Nicolas Le Nardou

asynchronous aqmp

07/04 2016

1.0.1

1.0.1.0

AMQP implementation based on PECL extension

  Sources   Download

The Requires

 

The Development Requires

by Nicolas Le Nardou

asynchronous aqmp

07/04 2016

1.0.0

1.0.0.0

AMQP implementation based on PECL extension

  Sources   Download

The Requires

 

The Development Requires

by Nicolas Le Nardou

asynchronous aqmp