added jsa.SendMsg for cherry-picked MQTT code

nats-io · Jun 21, 2024 · f4e9c50 · f4e9c50
1 parent eb022ef
commit f4e9c50
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/server/mqtt.go b/server/mqtt.go
@@ -1672,6 +1672,13 @@ func (jsa *mqttJSA) createDurableConsumer(cfg *CreateConsumerRequest) (*JSApiCon
 	return ccr, ccr.ToError()
 }
 
+func (jsa *mqttJSA) sendMsg(subj string, msg []byte) {
+	if subj == _EMPTY_ {
+		return
+	}
+	jsa.sendq.push(&mqttJSPubMsg{subj: subj, msg: msg, hdr: -1})
+}
+
 // if noWait is specified, does not wait for the JS response, returns nil
 func (jsa *mqttJSA) deleteConsumer(streamName, consName string, noWait bool) (*JSApiConsumerDeleteResponse, error) {
 	subj := fmt.Sprintf(JSApiConsumerDeleteT, streamName, consName)