The credit_flow between publishing AMQP 0.9.1 channel (or MQTT
connection) and (non-mirrored) classic queue processes was
unintentionally removed in 4.0 together with anything else related to
CQ mirroring.
By default we restore the 3.x behaviour for non-mirored classic
queues. It is possible to disable flow-control (the earlier 4.0.x
behaviour) with the new env `classic_queue_flow_control`. In 3.x this
was possible with the config `mirroring_flow_control`.
(cherry picked from commit
|
||
---|---|---|
.. | ||
include | ||
priv/schema | ||
src | ||
test | ||
.gitignore | ||
BUILD.bazel | ||
CODE_OF_CONDUCT.md | ||
CONTRIBUTING.md | ||
LICENSE | ||
LICENSE-MPL-RabbitMQ | ||
Makefile | ||
README.md | ||
app.bzl |
README.md
RabbitMQ MQTT Plugin
Getting Started
This is an MQTT plugin for RabbitMQ.
The plugin is included in the RabbitMQ distribution. To enable it, use rabbitmq-plugins:
rabbitmq-plugins enable rabbitmq_mqtt
Default port used by the plugin is 1883
.
Documentation
MQTT plugin documentation is available from rabbitmq.com.
Contributing
See CONTRIBUTING.md.
Running Tests
After cloning RabbitMQ umbrella repository, change into the rabbitmq-mqtt
directory
and run
make tests
This will bring up a RabbitMQ node with the plugin enabled and run integration tests
against it. Note that there must be no other MQTT server running on ports 1883
and 8883
.
Copyright and License
(c) 2007-2024 Broadcom. The term “Broadcom” refers to Broadcom Inc. and/or its subsidiaries. All rights reserved.
Released under the Mozilla Public License, the same as RabbitMQ.