nsqd: if mem-queue-size=0, ephemeral channel still needs mem-queue

use unbuffered mem-queue in this case, like nsqd 1.2.0
nsqio · Jan 6, 2022 · 786c1f2 · 786c1f2
1 parent ead7369
commit 786c1f2
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/nsqd/channel.go b/nsqd/channel.go
@@ -99,6 +99,10 @@ func NewChannel(topicName string, channelName string, nsqd *NSQD,
 	if strings.HasSuffix(channelName, "#ephemeral") {
 		c.ephemeral = true
 		c.backend = newDummyBackendQueue()
+		if c.memoryMsgChan == nil {
+			// MemQueueSize==0
+			c.memoryMsgChan = make(chan *Message)
+		}
 	} else {
 		dqLogf := func(level diskqueue.LogLevel, f string, args ...interface{}) {
 			opts := nsqd.getOpts()