From d400664b67cd0f4dcb03e2b618cbfc7ec5be25f6 Mon Sep 17 00:00:00 2001 From: Tomasz Pietrek Date: Mon, 27 Feb 2023 13:12:44 +0100 Subject: [PATCH] Fix source header name retrieval Stream subject mapping added index prefix to Nats-Stream-Source which was stripped when retrieving that header. That caused startingSequenceForSources to iterate over whole stream because of name mismatch. Stripping was removed in this commit. Signed-off-by: Tomasz Pietrek --- server/stream.go | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/server/stream.go b/server/stream.go index e1fbabb9..c8e59d37 100644 --- a/server/stream.go +++ b/server/stream.go @@ -2850,10 +2850,8 @@ func (mset *stream) processInboundSourceMsg(si *sourceInfo, m *inMsg) bool { // Generate a new style source header. func (si *sourceInfo) genSourceHeader(reply string) string { var b strings.Builder - // strip the source index number from the iname - name := si.iname[strings.IndexRune(si.iname, ':')+1:] - b.WriteString(name) + b.WriteString(si.iname) b.WriteByte(' ') // Grab sequence as text here from reply subject. var tsa [expectedNumReplyTokens]string