Active configuration
Current broker connection status
Gracefully terminates the MQTT client connection
Connects to the MQTT broker and sets up event listeners
Starts a background listener on a given queue topic or MQTT wildcard pattern Implements AbstractQueueAdapter.listen()
Optional_params: { concurrency?: number; gpu?: boolean }Publishes a message payload to a specified MQTT topic Implements AbstractQueueAdapter.send()
Universal MQTT Queue Adapter for Quatrain Extends AbstractQueueAdapter from @quatrain/queue to provide high-performance, non-blocking asynchronous message publishing and subscription across Mosquitto, EMQX, HiveMQ, AWS IoT, and RabbitMQ MQTT brokers.