Release lock for sending non-consumer messages as well

Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2020-11-16 05:29:55 -08:00
parent e93f448d32
commit cccb96097a

View File

@@ -551,7 +551,12 @@ func (mset *Stream) AddConsumer(config *ConsumerConfig) (*Consumer, error) {
// Do all advisory sends here.
// Lock should be held on entry but will be released.
func (o *Consumer) sendAdvisory(subj string, msg []byte) {
o.sendq <- &jsPubMsg{subj, subj, _EMPTY_, nil, msg, nil, 0}
sendq := o.sendq
o.mu.Unlock()
if sendq != nil {
sendq <- &jsPubMsg{subj, subj, _EMPTY_, nil, msg, nil, 0}
}
o.mu.Lock()
}
func (o *Consumer) sendDeleteAdvisoryLocked() {