patrick/Sonoff4ChPro
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

mqtt buffer size FIX

Browse Source
This commit is contained in:
Patrick Haßel 2025-09-03 14:27:43 +02:00
parent d4282d3fba
commit b8d79dbc67
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/mqtt.cpp
View File

@ -85,6 +85,7 @@ void mqttLoop() {
if (mqttLast == 0 || millis() - mqttLast >= 3000) { if (mqttLast == 0 || millis() - mqttLast >= 3000) {
mqttLast = max(1UL, millis()); mqttLast = max(1UL, millis());
client.setServer(mqttHost.c_str(), mqttPort); client.setServer(mqttHost.c_str(), mqttPort);
client.setBufferSize(512);
Serial.printf("[MQTT] Connecting: %s:%ld\n", mqttHost.c_str(), mqttPort); Serial.printf("[MQTT] Connecting: %s:%ld\n", mqttHost.c_str(), mqttPort);
if (client.connect(WiFi.getHostname(), mqttUser.c_str(), mqttPass.c_str())) { if (client.connect(WiFi.getHostname(), mqttUser.c_str(), mqttPass.c_str())) {
Serial.printf("[MQTT] Connected.\n"); Serial.printf("[MQTT] Connected.\n");
@ -106,9 +107,9 @@ void mqttPublish(const String &topic, const JsonDocument &json) {
if (!mqttShouldConnect) { if (!mqttShouldConnect) {
return; return;
} }
char buffer[256]; char buffer[512];
const auto size = serializeJson(json, buffer); serializeJson(json, buffer);
client.publish(topic.c_str(), buffer, size); client.publish(topic.c_str(), buffer);
} }
String getMqttUser() { String getMqttUser() {