Skip to content

Commit

Permalink
Merge pull request #1022 from bruth/patch-1
Browse files Browse the repository at this point in the history
[FIXED] Ephemeral PullConsumer's Fetch() would fail with "no responders"
  • Loading branch information
kozlovic committed Jul 29, 2022
2 parents daee313 + 726f0d8 commit dcf9b93
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions js.go
Expand Up @@ -1695,6 +1695,9 @@ func (js *js) subscribe(subj, queue string, cb MsgHandler, ch chan *Msg, isSync,
// after the AddConsumer returns.
if consumer == _EMPTY_ {
sub.jsi.consumer = info.Name
if isPullMode {
sub.jsi.nms = fmt.Sprintf(js.apiSubj(apiRequestNextT), stream, info.Name)
}
}
sub.mu.Unlock()
}
Expand Down

0 comments on commit dcf9b93

Please sign in to comment.