From 59db0928762c21afb449d82bfc02d1630dab4d3b Mon Sep 17 00:00:00 2001 From: Lev Brouk Date: Fri, 21 Jun 2024 08:11:28 -0700 Subject: [PATCH] restored the original newRequest, not Ex --- server/mqtt.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/mqtt.go b/server/mqtt.go index a4ec6dd7cef..19350850066 100644 --- a/server/mqtt.go +++ b/server/mqtt.go @@ -1709,7 +1709,7 @@ func (jsa *mqttJSA) deleteConsumer(streamName, consName string, noWait bool) (*J return nil, nil } - cdri, err := jsa.newRequestEx(mqttJSAConsumerDel, subj, _EMPTY_, -1, nil, mqttJSAPITimeout) + cdri, err := jsa.newRequest(mqttJSAConsumerDel, subj, 0, nil) if err != nil { return nil, err }