Skip to content

Commit 8346715

Browse files
committed
Fix outbound-mqtt bug with QoS 2
Signed-off-by: Brian H <[email protected]>
1 parent 86a5877 commit 8346715

File tree

1 file changed

+1
-1
lines changed
  • crates/outbound-mqtt/src

1 file changed

+1
-1
lines changed

crates/outbound-mqtt/src/lib.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ impl v2::HostConnection for OutboundMqtt {
108108
match (qos, event) {
109109
(QoS::AtMostOnce, Event::Outgoing(Outgoing::Publish(_)))
110110
| (QoS::AtLeastOnce, Event::Incoming(Incoming::PubAck(_)))
111-
| (QoS::ExactlyOnce, Event::Outgoing(Outgoing::PubComp(_))) => break,
111+
| (QoS::ExactlyOnce, Event::Incoming(Incoming::PubComp(_))) => break,
112112

113113
(_, _) => continue,
114114
}

0 commit comments

Comments
 (0)