dataprocessors/amqp-async

Async AMQP 0.9.1 client for PHP designed to work with Icicle.

v1.0.10 2018-02-06 01:16 UTC

Requires

• php: >=7.0
• ext-bcmath: *
• icicleio/icicle: ^0.9
• icicleio/socket: ^0.5
• icicleio/stream: ^0.5

Requires (Dev)

• phpunit/phpunit: ^5.0

LGPL-2.1

• Data Processors

• queue
• rabbitmq
• message

README

amqp-async is an implementation of the AMQP 0.9.1 protocol for PHP designed to work with Icicle.

Potentially supporting Amp in the future.

Requirements

• PHP 7.0+

Installation

The recommended way to install amqp-async is with the Composer package manager. (See the Composer installation guide for information on installing and using Composer.)

Run the following command to use the library in your project:

composer require dataprocessors/amqp-async

You can also manually edit composer.json to add amqp-async as a project requirement.

// composer.json
{
    "require": {
        "dataprocessors/amqp-async": "1.0.*"
    }
}

Example

<?php
require_once "vendor/autoload.php";

class Demo {

  public function go() {
    $conn = new DataProcessors\AMQP\AMQPConnection();
    yield $conn->connect('127.0.0.1', 5672, 'guest', 'guest');
    $channel = yield $conn->channel();
    yield $channel->basic_consume('test', '', false, false, false, false,
      function($msg) {
        echo "Got a message\n";
      }
    );
  }

}

$demo = new Demo();
$coroutine = new Icicle\Coroutine\Coroutine($demo->go());
Icicle\Loop\run();

Credits

amqp-async is based on php-amqplib