dani/CommandStation-EX
1
0
Fork 0
mirror of https://github.com/DCC-EX/CommandStation-EX.git synced 2024-11-27 01:56:14 +01:00
Code Releases Activity

update #1

Browse Source
This commit is contained in:
Gregor Baues 2021-05-03 09:05:05 +02:00
parent 6bd9e28be4
commit 851228fba6
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
DccMQTT.cpp
View File

@ -35,8 +35,8 @@
#include <Ethernet.h> #include <Ethernet.h>
#include <Dns.h> #include <Dns.h>
#include <DCCTimer.h> #include <DCCTimer.h>
#include <DccMQTT.h> #include <DccMQTT.h>
#include <Queue.h>
//--------- //---------
// Variables // Variables
@ -74,8 +74,7 @@ void mqttCallback(char *topic, byte *payload, unsigned int length)
topicMessage[0] = '\0'; topicMessage[0] = '\0';
strcpy(topicName, topic); strcpy(topicName, topic);
strlcpy(topicMessage, (char *)payload, length + 1); strlcpy(topicMessage, (char *)payload, length + 1);
Serial.println("some msg arrived"); DIAG(F("MQTT Message arrived [%s]: [%s]"), topicName, topicMessage);
DIAG(F("MQTT Message arrived [%s]: %s"), topicName, topicMessage);
} }
/** /**
@ -113,7 +112,7 @@ void DccMQTT::connect()
case 6: case 6:
case 1: case 1:
{ // port(p), ip(i), domain(d), { // port(p), ip(i), domain(d),
if (mqttClient.connect(clientID)) if (mqttClient.connect(connectID))
{ {
DIAG(F("MQTT broker connected ...")); DIAG(F("MQTT broker connected ..."));
} }