Fixed issue with the input node handling errors emitted from MqttClient.