fix: 修复集群消息未 subscribe 的 bug

Amazingwujun · Amazingwujun · commit f20c0b6e322a · 2022-04-26T11:54:33.000+08:00
diff --git a/src/main/java/com/jun/mqttx/broker/BrokerHandler.java b/src/main/java/com/jun/mqttx/broker/BrokerHandler.java
@@ -378,7 +378,7 @@ public void action(byte[] msg) {
 
         // 移除 cache&redis 中客户端订阅的 topic
         if (!CollectionUtils.isEmpty(authorizedSub)) {
-            subscriptionService.clearUnAuthorizedClientSub(clientId, authorizedSub);
+            subscriptionService.clearUnAuthorizedClientSub(clientId, authorizedSub).subscribe();
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -378,7 +378,7 @@ public void action(byte[] msg) {`
`378`	`378`
`379`	`379`	`// 移除 cache&redis 中客户端订阅的 topic`
`380`	`380`	`if (!CollectionUtils.isEmpty(authorizedSub)) {`
`381`		`- subscriptionService.clearUnAuthorizedClientSub(clientId, authorizedSub);`
	`381`	`+ subscriptionService.clearUnAuthorizedClientSub(clientId, authorizedSub).subscribe();`
`382`	`382`	`}`
`383`	`383`	`}`
`384`	`384`