fix amqtt credentials

This commit is contained in:
debsahu 2018-04-10 15:36:41 -04:00
parent 88d299f430
commit f3b6abb52b

View file

@ -428,6 +428,7 @@ void setup() {
amqttClient.onDisconnect(onMqttDisconnect); amqttClient.onDisconnect(onMqttDisconnect);
amqttClient.onMessage(onMqttMessage); amqttClient.onMessage(onMqttMessage);
amqttClient.setServer(mqtt_host, String(mqtt_port).toInt()); amqttClient.setServer(mqtt_host, String(mqtt_port).toInt());
amqttClient.setCredentials(mqtt_user, mqtt_pass);
amqttClient.setClientId(mqtt_clientid); amqttClient.setClientId(mqtt_clientid);
connectToMqtt(); connectToMqtt();