Legacy MqttConnection from MQTT.js, with no backpressure!