From 5aa3dd7761b67f790d0a2d1b8fb7585cbb3c65f1 Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Tue, 20 Apr 2021 13:35:48 -0700 Subject: [PATCH] Put back direct consumer subject prefix Signed-off-by: Derek Collison --- server/stream.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/server/stream.go b/server/stream.go index 62c4e1a2..6cfc9bab 100644 --- a/server/stream.go +++ b/server/stream.go @@ -1386,7 +1386,7 @@ func (mset *stream) setupMirrorConsumer() error { if ext != nil { deliverSubject = strings.ReplaceAll(ext.DeliverPrefix+syncSubject(".M"), "..", ".") } else { - deliverSubject = syncSubject("$JSDC.M") + deliverSubject = syncSubject("$JS.M") } if !isReset { @@ -1593,7 +1593,7 @@ func (mset *stream) setSourceConsumer(sname string, seq uint64) { if ext != nil { deliverSubject = strings.ReplaceAll(ext.DeliverPrefix+syncSubject(".S"), "..", ".") } else { - deliverSubject = syncSubject("$JSDC.S") + deliverSubject = syncSubject("$JS.S") } if !si.grr {