This is an automated email from the ASF dual-hosted git repository.
dongyuanpan pushed a commit to branch develop_mqtt5.0
in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git
The following commit(s) were added to refs/heads/develop_mqtt5.0 by this push:
new 879557b serverReceiveMaximum to 32767
879557b is described below
commit 879557ba210f87177c5d0c55cae6cfbe30d7a560
Author: dongyuan.pdy <dongyuanp...@gmail.com>
AuthorDate: Mon Jul 1 17:02:26 2024 +0800
serverReceiveMaximum to 32767
---
.../src/main/java/org/apache/rocketmq/mqtt/cs/config/ConnectConf.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config/ConnectConf.java
b/mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config/ConnectConf.java
index f998adc..904b66d 100644
--- a/mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config/ConnectConf.java
+++ b/mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config/ConnectConf.java
@@ -77,7 +77,7 @@ public class ConnectConf {
private boolean enableRetain = false;
private boolean enableSubscriptionIdentifier = false;
private int topicAliasMaximum = 10;
- private int serverReceiveMaximum = 65535;
+ private int serverReceiveMaximum = 32767;
private int maxTransferCountOnMessageInDisk = 8;
public ConnectConf() throws IOException {
