WithGetMsgSubject sets the stream subject from which the message should be retrieved. Server will return a first message with a seq >= to the input seq that has the specified subject.
(subject string)
| 118 | // retrieved. Server will return a first message with a seq >= to the input seq |
| 119 | // that has the specified subject. |
| 120 | func WithGetMsgSubject(subject string) GetMsgOpt { |
| 121 | return func(req *apiMsgGetRequest) error { |
| 122 | req.NextFor = subject |
| 123 | return nil |
| 124 | } |
| 125 | } |
| 126 | |
| 127 | // PullMaxMessages limits the number of messages to be buffered in the client. |
| 128 | // If not provided, a default of 500 messages will be used. |