mqtt: PAHO buffer expansion

viacheslauK · viacheslauK · commit d5fa5d9586ff · 2025-12-23T10:02:31.000+01:00
diff --git a/mqtt_streaming_protocol/src/MqttAsyncClient.cpp b/mqtt_streaming_protocol/src/MqttAsyncClient.cpp
@@ -34,6 +34,7 @@ MqttAsyncClient::MqttAsyncClient(std::string serverUrl, std::string clientId, bo
     disconnOpts.context = this;
 
     createOpts = MQTTAsync_createOptions_initializer;
+    createOpts.maxBufferedMessages = 1000;
 }
 
 MqttAsyncClient::~MqttAsyncClient()

Original file line number	Diff line number	Diff line change
`@@ -34,6 +34,7 @@ MqttAsyncClient::MqttAsyncClient(std::string serverUrl, std::string clientId, bo`
`34`	`34`	`disconnOpts.context = this;`
`35`	`35`
`36`	`36`	`createOpts = MQTTAsync_createOptions_initializer;`
	`37`	`+ createOpts.maxBufferedMessages = 1000;`
`37`	`38`	`}`
`38`	`39`
`39`	`40`	`MqttAsyncClient::~MqttAsyncClient()`