feat: read unsubscribe packet in v5 (#626)

bytebeamio · May 30, 2023 · 1654935 · 1654935
1 parent 7a4b895
commit 1654935
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/rumqttd/CHANGELOG.md b/rumqttd/CHANGELOG.md
@@ -18,6 +18,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 ### Removed
 
 ### Fixed
+- MQTTv5: Read the Unsubscribe package in match arms (#625)
 
 ### Security
 

diff --git a/rumqttd/src/protocol/v5/mod.rs b/rumqttd/src/protocol/v5/mod.rs
@@ -404,6 +404,10 @@ impl Protocol for V5 {
                 let (suback, properties) = suback::read(fixed_header, packet)?;
                 Packet::SubAck(suback, properties)
             }
+            Packet::Unsubscribe => {
+                let (unsubscribe, properties) = unsubscribe::read(fixed_header, packet)?;
+                Packet::Unsubscribe(unsubscribe, properties)
+            }
             PacketType::PingReq => Packet::PingReq(PingReq),
             PacketType::PingResp => Packet::PingResp(PingResp),
             PacketType::Disconnect => {