admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-01-07 19:31:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

[skip e2e]Add comment for rmq reader (#13624)

Browse Source 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
This commit is contained in:
yukun 2021-12-23 17:05:13 +08:00 committed by GitHub
parent 83ef9a9ba1
commit ee2027be87
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
internal/util/mqclient/rmq_reader.go
View File

@ -32,6 +32,7 @@ func (rr *rmqReader) HasNext() bool {
return rr.r.HasNext()
}
// Seek seeks the reader position to id
func (rr *rmqReader) Seek(id MessageID) error {
msgID := id.(*rmqID).messageID
return rr.r.Seek(msgID)