close channel if not delete

absolute8511 · May 16, 2017 · 656a436 · 656a436
1 parent 90c2ea3
commit 656a436
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/nsqd/topic.go b/nsqd/topic.go
@@ -643,6 +643,8 @@ func (t *Topic) CloseExistingChannel(channelName string, deleteData bool) error
 	// (so that we dont leave any messages around)
 	if deleteData {
 		channel.Delete()
+	} else {
+		channel.Close()
 	}
 
 	if numChannels == 0 && t.ephemeral == true {