gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-16 19:14:41 -07:00
Code Issues Packages Projects Releases Wiki Activity

Delete no longer needed

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2021-03-10 07:15:58 -05:00
parent f95b6481d2
commit 263f4452c3
1 changed files with 0 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
server/stream.go
View File

@@ -1757,24 +1757,6 @@ func (mset *stream) removeInternalConsumer(si *sourceInfo) {
if si == nil || si.cname == _EMPTY_ {
return
}
var ext *ExternalStream
if si == mset.mirror {
ext = mset.cfg.Mirror.External
} else {
ssi := mset.streamSource(si.name)
if ssi == nil {
return
}
ext = ssi.External
}
subject := fmt.Sprintf(JSApiConsumerDeleteT, si.name, si.cname)
if ext != nil {
subject = strings.Replace(subject, JSApiPrefix, ext.ApiPrefix, 1)
subject = strings.ReplaceAll(subject, "..", ".")
}
mset.outq.send(&jsPubMsg{subject, _EMPTY_, _EMPTY_, nil, nil, nil, 0, nil})
si.cname = _EMPTY_
}