Removed commented out code

nats-io · Jun 20, 2024 · 00efd84 · 00efd84
1 parent ddda72d
commit 00efd84
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/server/mqtt.go b/server/mqtt.go
@@ -3497,7 +3497,6 @@ func (sess *mqttSession) deleteConsumer(cc *ConsumerConfig) {
  sess.mu.Lock()
  sess.tmaxack -= cc.MaxAckPending
  sess.jsa.deleteConsumer(mqttStreamName, cc.Durable, true)
- // sess.jsa.sendq.push(&mqttJSPubMsg{subj: sess.jsa.prefixDomain(fmt.Sprintf(JSApiConsumerDeleteT, mqttStreamName, cc.Durable))})
  sess.mu.Unlock()
 }