gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-17 11:24:44 -07:00
Code Issues Packages Projects Releases Wiki Activity

Interest based retention should not store if no consumers present.

Browse Source 
Fix for https://github.com/nats-io/jetstream/issues/314

Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2020-09-02 16:04:38 -07:00
parent d794616945
commit cdbea93a87
2 changed files with 15 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
server/stream.go
View File

@@ -760,6 +760,7 @@ func (mset *Stream) processInboundJetStreamMsg(_ *subscription, pc *client, subj
name := mset.config.Name
maxMsgSize := int(mset.config.MaxMsgSize)
numConsumers := len(mset.consumers)
interestRetention := mset.config.Retention == InterestPolicy
// Process msgId if we have headers.
var msgId string
@@ -795,7 +796,7 @@ func (mset *Stream) processInboundJetStreamMsg(_ *subscription, pc *client, subj
// Check to see if we are over the account limit.
if maxMsgSize >= 0 && len(msg) > maxMsgSize {
response = []byte("-ERR 'message size exceeds maximum allowed'")
} else {
} else if !interestRetention || numConsumers > 0 {
// Headers.
if pc != nil && pc.pa.hdr > 0 {
hdr = msg[:pc.pa.hdr]