PHPackages                             markkimsal/amphp-mqtt - 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. markkimsal/amphp-mqtt

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

markkimsal/amphp-mqtt
=====================

Async MQTT client for Amp.

1.3.0(7y ago)61223MITPHP

Since May 22Pushed 7y ago2 watchersCompare

[ Source](https://github.com/markkimsal/amphp-mqtt)[ Packagist](https://packagist.org/packages/markkimsal/amphp-mqtt)[ RSS](/packages/markkimsal-amphp-mqtt/feed)WikiDiscussions master Synced today

READMEChangelogDependencies (4)Versions (7)Used By (0)

MQTT
====

[](#mqtt)

`markkimsal/amphp-mqtt` is an asynchronous MQTT client for PHP based on Amp.

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

[](#installation)

```
composer require markkimsal/amphp-mqtt

```

This project does not require any PHP extensions.

Usage
-----

[](#usage)

Every publish or subscribe returns an `Amp\Promise` that you can react to when it's resolved. Messages are received from `->on('message')` and that takes a callback with only 1 argument: the `Packet\Publish` class. `Packet\Publish` is used for both sending and receiving messages.

You can start sending and subscribing before the connection ack packet is received and the system will queue up your packets but still return a `Amp\Promise` immediately.

QoS 0 packets will resolve as soon as they are sent as they will not get any acknowledgement from the server.

QoS 1 packets will resolve when the client gets a Puback packet.

QoS 2 packets will resolve when the client gets a Pubcomp packet. The client will automatically respond to Pubrec with a Pubrel as per the spec.

Supports TLSv1.2 by using "tls://" prefix to the URI of the server. Peer verification is not done.

Supports username and password authentication as parameters of the connection URL.

```