~/Projects/comqtt
git clone https://code.lsong.org/comqtt
Commit
- Commit
- d639a5397042092128fd1f55c3c22e56c19b1233
- Author
- Wind <[email protected]>
- Date
- 2023-05-18 22:42:34 +0800 +0800
- Diffstat
cluster/storage/redis/redis.go | 3 +++
Merge pull request #41 from fxk2006/patch-2
Update redis.go
diff --git a/cluster/storage/redis/redis.go b/cluster/storage/redis/redis.go
index df487eb6116a41c51a72b0193f9430fbdb31985c..30523a99be95a2da7b0225e5cba86c70daaee08e 100644
--- a/cluster/storage/redis/redis.go
+++ b/cluster/storage/redis/redis.go
@@ -216,6 +216,9 @@ }
var in *storage.Subscription
for i := 0; i < len(pk.Filters); i++ {
+ if reasonCodes[i] == 0x80 {
+ continue
+ }
in = &storage.Subscription{
Qos: reasonCodes[i],
Identifier: pk.Filters[i].Identifier,
