gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Put back direct consumer subject prefix

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2021-04-20 13:35:48 -07:00
parent 0a3e54c88a
commit 5aa3dd7761
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
server/stream.go
View File

@@ -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 {