mirror of https://github.com/milvus-io/milvus.git
[skip ci]Add comment for rocksmq reader (#12569)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>pull/12579/head
parent
79f1216f9d
commit
fa4372a597
|
@ -1042,6 +1042,7 @@ func (rmq *rocksmq) ReaderSeek(topicName string, readerName string, msgID Unique
|
|||
reader.Seek(msgID)
|
||||
}
|
||||
|
||||
// Next get the next message of reader
|
||||
func (rmq *rocksmq) Next(ctx context.Context, topicName string, readerName string, messageIDInclusive bool) (*ConsumerMessage, error) {
|
||||
if rmq.isClosed() {
|
||||
return nil, errors.New(RmqNotServingErrMsg)
|
||||
|
|
Loading…
Reference in New Issue