resetPendingMsgs resets pending message count and byte count to the values set in consumeOpts lock should be held before calling this method
()
| 429 | // to the values set in consumeOpts |
| 430 | // lock should be held before calling this method |
| 431 | func (s *pullSubscription) resetPendingMsgs() { |
| 432 | s.pending.msgCount = s.consumeOpts.MaxMessages |
| 433 | s.pending.byteCount = s.consumeOpts.MaxBytes |
| 434 | } |
| 435 | |
| 436 | // decrementPendingMsgs decrements pending message count and byte count |
| 437 | // lock should be held before calling this method |