MQTT GW: Add INDICATION_GW_RX (#1228)

tekka007 · mfalkvidd · commit 121648f34bb4 · 2018-11-12T21:36:10.000+01:00
diff --git a/core/MyGatewayTransportMQTTClient.cpp b/core/MyGatewayTransportMQTTClient.cpp
@@ -119,10 +119,11 @@ bool gatewayTransportSend(MyMessage &message)
 	return _MQTT_client.publish(topic, message.getString(_convBuffer), retain);
 }
 
-void incomingMQTT(char* topic, uint8_t* payload, unsigned int length)
+void incomingMQTT(char *topic, uint8_t *payload, unsigned int length)
 {
 	GATEWAY_DEBUG(PSTR("GWT:IMQ:TOPIC=%s, MSG RECEIVED\n"), topic);
 	_MQTT_available = protocolMQTTParse(_MQTT_msg, topic, payload, length);
+	setIndication(INDICATION_GW_RX);
 }
 
 bool reconnectMQTT(void)

Original file line number	Diff line number	Diff line change
`@@ -119,10 +119,11 @@ bool gatewayTransportSend(MyMessage &message)`
`119`	`119`	`return _MQTT_client.publish(topic, message.getString(_convBuffer), retain);`
`120`	`120`	`}`
`121`	`121`
`122`		`-void incomingMQTT(char* topic, uint8_t* payload, unsigned int length)`
	`122`	`+void incomingMQTT(char topic, uint8_t payload, unsigned int length)`
`123`	`123`	`{`
`124`	`124`	`GATEWAY_DEBUG(PSTR("GWT:IMQ:TOPIC=%s, MSG RECEIVED\n"), topic);`
`125`	`125`	`_MQTT_available = protocolMQTTParse(_MQTT_msg, topic, payload, length);`
	`126`	`+ setIndication(INDICATION_GW_RX);`
`126`	`127`	`}`
`127`	`128`
`128`	`129`	`bool reconnectMQTT(void)`