Next is used to retrieve the next message from the consumer. This method will block until the message is retrieved or the timeout is reached.
(opts ...FetchOpt)
| 152 | // method will block until the message is retrieved or the timeout |
| 153 | // is reached. |
| 154 | Next(opts ...FetchOpt) (Msg, error) |
| 155 | |
| 156 | // Info fetches current ConsumerInfo from the server. |
| 157 | Info(context.Context) (*ConsumerInfo, error) |
no outgoing calls