fix

Signed-off-by: Derek Collison <derek@nats.io>

server/consumer.go

@@ -752,11 +752,11 @@ func (o *consumer) checkQueueInterest() {
 // clears our node if we have one. When we scale down to 1.
 func (o *consumer) clearNode() {
 	o.mu.Lock()
+	defer o.mu.Unlock()
 	if o.node != nil {
 		o.node.Delete()
 		o.node = nil
 	}
-	defer o.mu.Unlock()
 }
 
 // Lock should be held.

server/stream.go

@@ -3240,7 +3240,7 @@ func (mset *stream) internalLoop() {
 			c.flushClients(0)
 			outq.recycle(&pms)
 		case <-msgs.ch:
-			// This can possible change now so needs to be checked here.
+			// This can possibly change now so needs to be checked here.
 			mset.mu.RLock()
 			isClustered := mset.node != nil
 			mset.mu.RUnlock()