PHPackages                             thesis/amqp - PHPackages - PHPackages  [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register)

1. [Directory](/)
2. /
3. [Queues & Workers](/categories/queues)
4. /
5. thesis/amqp

ActiveLibrary[Queues & Workers](/categories/queues)

thesis/amqp
===========

Async (fiber based) client for AMQP 0.9.1

1.0.2(10mo ago)10438.6k↓61.4%4[3 issues](https://github.com/thesis-php/amqp/issues)[2 PRs](https://github.com/thesis-php/amqp/pulls)5MITPHPPHP ^8.3CI passing

Since Jan 22Pushed 5mo ago2 watchersCompare

[ Source](https://github.com/thesis-php/amqp)[ Packagist](https://packagist.org/packages/thesis/amqp)[ Fund](https://www.tinkoff.ru/cf/5MqZQas2dk7)[ RSS](/packages/thesis-amqp/feed)WikiDiscussions 1.0.x Synced 1w ago

READMEChangelog (7)Dependencies (17)Versions (18)Used By (5)

Thesis Amqp
===========

[](#thesis-amqp)

Pure asynchronous (fiber based) strictly typed full-featured PHP driver for AMQP 0.9.1 protocol.

Features
--------

[](#features)

- Full support for AMQP 0.9.1
- [Supports AMQP uri specification](#configuration)
- [Publish messages in batch](examples/publishBatch.php)
- [Automatic acknowledges processing in Publisher Confirms mode](examples/publishConfirm.php)
- [Automatic returns processing in Publisher Confirms mode and mandatory flag enabled](examples/explicitReturn.php)
- [A more convenient way to work with transactions](examples/transactional.php)
- [Consume messages as concurrent iterator](examples/consumeIterator.php)
- [Consume messages in batch](examples/consumeBatch.php)
- [Native support for RPC](#rpc)

Installation
------------

[](#installation)

```
composer require thesis/amqp
```

Usage
-----

[](#usage)

- [Configuration](#configuration)
- [Client](#client)
- [Channel](#channel)
- [Publish a message](#publish-a-message)
- [Safety](#safety)
- [Consume a batch of messages](#consume-a-batch-of-messages)
- [Confirms](#confirms)
- [Explicit returns](#explicit-returns)
- [RPC](#rpc)
- [License](#license)

### Configuration

[](#configuration)

Configuration can be created from dsn, that follows the [amqp uri spec](https://www.rabbitmq.com/docs/uri-spec).

```