Keeps track of the incoming message's reply subject so that the consumer's state (deliver sequence, etc..) can be checked against heartbeats. We will also bump the incoming data message sequence that is used in FC cases. Runs under the subscription lock
(reply string)
| 2141 | // We will also bump the incoming data message sequence that is used in FC cases. |
| 2142 | // Runs under the subscription lock |
| 2143 | func (sub *Subscription) trackSequences(reply string) { |
| 2144 | // For flow control, keep track of incoming message sequence. |
| 2145 | sub.jsi.fciseq++ |
| 2146 | sub.jsi.cmeta = reply |
| 2147 | } |
| 2148 | |
| 2149 | // Check to make sure messages are arriving in order. |
| 2150 | // Returns true if the sub had to be replaced. Will cause upper layers to return. |