Erweiterungen
This commit is contained in:
1 parent
88dc13391d
commit
75787d51ff
6 files changed
+731
-5
No files matched your search
@@ -137,7 +137,7 @@ class MqttCore {
|
||||
|
||||
_mqttClient.publishMessage(topic, MqttQos.exactlyOnce, buffer);
|
||||
|
||||
Util.logInfo("message $text send to $topic");
|
||||
Util.logInfo("message\n$text\nsend to $topic");
|
||||
}
|
||||
|
||||
publishPayloadMessage(String topic, Map<String, dynamic> payload) {
|
||||
@@ -165,9 +165,7 @@ class MqttCore {
|
||||
String payload = utf8.decode(MqttPublishPayload.bytesToStringAsString(message.payload.message).codeUnits);
|
||||
var topic = message.variableHeader?.topicName;
|
||||
|
||||
Util.logInfo('message received');
|
||||
Util.logInfo('topic: $topic');
|
||||
Util.logInfo('message: $payload');
|
||||
Util.logInfo('message received\ntopic: $topic\nmessage: $payload');
|
||||
|
||||
Map<String, dynamic> messageData = jsonDecode(payload);
|
||||
|
||||
|
||||
Reference in new issue
Block a user