mirror of https://github.com/milvus-io/milvus.git
[skip ci]Add rmq_imple seek comments (#11273)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>pull/11282/head
parent
872f6f8a04
commit
c05ed4c365
|
@ -648,6 +648,7 @@ func (rmq *rocksmq) Consume(topicName string, groupName string, n int) ([]Consum
|
|||
return consumerMessage, nil
|
||||
}
|
||||
|
||||
// seek is used for internal call without the topicMu
|
||||
func (rmq *rocksmq) seek(topicName string, groupName string, msgID UniqueID) error {
|
||||
rmq.storeMu.Lock()
|
||||
defer rmq.storeMu.Unlock()
|
||||
|
|
Loading…
Reference in New Issue