Skip to content

Commit a072c1f

Browse files
Merge pull request #2420 from fibonacci1729/fix-outbound-mqtt
Fix outbound-mqtt bug with QoS 2
2 parents 57610ec + 8346715 commit a072c1f

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)