Skip to content

Commit

Permalink
Merge pull request #1106 from neilalexander/patch-1
Browse files Browse the repository at this point in the history
Update `InactiveThreshold` comments
  • Loading branch information
derekcollison authored Oct 15, 2022
2 parents 885ad13 + 0689e7a commit 888a91d
Showing 1 changed file with 7 additions and 3 deletions.
10 changes: 7 additions & 3 deletions js.go
Original file line number Diff line number Diff line change
Expand Up @@ -1088,7 +1088,7 @@ type ConsumerConfig struct {
DeliverSubject string `json:"deliver_subject,omitempty"`
DeliverGroup string `json:"deliver_group,omitempty"`

// Ephemeral inactivity threshold.
// Inactivity threshold.
InactiveThreshold time.Duration `json:"inactive_threshold,omitempty"`

// Generally inherited by parent stream and other markers, now can be configured directly.
Expand Down Expand Up @@ -2465,8 +2465,12 @@ func MaxRequestMaxBytes(bytes int) SubOpt {
})
}

// InactiveThreshold indicates how long the server should keep an ephemeral
// after detecting loss of interest.
// InactiveThreshold indicates how long the server should keep a consumer
// after detecting a lack of activity. In NATS Server 2.8.4 and earlier, this
// option only applies to ephemeral consumers. In NATS Server 2.9.0 and later,
// this option applies to both ephemeral and durable consumers, allowing durable
// consumers to also be deleted automatically after the inactivity threshold has
// passed.
func InactiveThreshold(threshold time.Duration) SubOpt {
return subOptFn(func(opts *subOpts) error {
if threshold < 0 {
Expand Down

0 comments on commit 888a91d

Please sign in to comment.