Use filter_subject when calling extended consumer create API

The server consumer creation code is picky and does indeed not accept a request send to the ExT subject if that request specifies the subject filter in the array (even if there is only one entry in the array). Signed-off-by: Jean-Noël Moyne <[email protected]> Signed-off-by: Neil Twigg <[email protected]> Co-authored-by: Jean-Noël Moyne <[email protected]> Co-authored-by: Neil Twigg <[email protected]>
nats-io · Sep 20, 2023 · 40ce0a9 · 40ce0a9
1 parent ad63d70
commit 40ce0a9
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/server/stream.go b/server/stream.go
@@ -2895,7 +2895,11 @@ func (mset *stream) setSourceConsumer(iname string, seq uint64, startTime time.T
 		subject = fmt.Sprintf(JSApiConsumerCreateExT, si.name, req.Config.Name, req.Config.FilterSubject)
 	} else if len(req.Config.FilterSubjects) == 1 {
 		req.Config.Name = fmt.Sprintf("src-%s", createConsumerName())
-		subject = fmt.Sprintf(JSApiConsumerCreateExT, si.name, req.Config.Name, req.Config.FilterSubjects[0])
+		// It is necessary to switch to using FilterSubject here as the extended consumer
+		// create API checks for it, so as to not accidentally allow multiple filtered subjects.
+		req.Config.FilterSubject = req.Config.FilterSubjects[0]
+		req.Config.FilterSubjects = nil
+		subject = fmt.Sprintf(JSApiConsumerCreateExT, si.name, req.Config.Name, req.Config.FilterSubject)
 	} else {
 		subject = fmt.Sprintf(JSApiConsumerCreateT, si.name)
 	}