[Added] MQTT: QoS2 support (#4349)

@derekcollison @neilalexander @kozlovic #### Summary Adds MQTT QoS2 support - [X] Resolves #3244 - [X] Tests added - [x] Build is green in Travis CI
nats-io · Aug 29, 2023 · bd93f08 · bd93f08
2 parents 63f81ae + ad2e9d7
commit bd93f08
Show file tree

Hide file tree

Showing 4 changed files with 1,352 additions and 362 deletions.
diff --git a/server/client.go b/server/client.go
@@ -4223,7 +4223,7 @@ func (c *client) processServiceImport(si *serviceImport, acc *Account, msg []byt
 	c.pa.reply = nrr
 
 	if changed && c.isMqtt() && c.pa.hdr > 0 {
-		c.srv.mqttStoreQoS1MsgForAccountOnNewSubject(c.pa.hdr, msg, siAcc.GetName(), to)
+		c.srv.mqttStoreQoSMsgForAccountOnNewSubject(c.pa.hdr, msg, siAcc.GetName(), to)
 	}
 
 	// FIXME(dlc) - Do L1 cache trick like normal client?