✨ mica-mqtt-broker 优化，添加默认 stream 长度。

lets-mica · Jul 17, 2024 · 0d4a97a · 0d4a97a
1 parent fe8074d
commit 0d4a97a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...-broker/src/main/java/net/dreamlu/iot/mqtt/broker/cluster/RedisMqttMessageDispatcher.java b/...-broker/src/main/java/net/dreamlu/iot/mqtt/broker/cluster/RedisMqttMessageDispatcher.java
@@ -46,7 +46,8 @@ public boolean send(Message message) {
 		// 手动序列化和反序列化，避免 redis 序列化不一致问题
 		String topic = message.getTopic();
 		String key = topic == null ? message.getClientId() : topic;
-		streamTemplate.send(channel, key, message, messageSerializer::serialize);
+		long maxLen = 10_0000;
+		streamTemplate.send(channel, key, message, messageSerializer::serialize, maxLen);
 		return true;
 	}