Skip to content
Snippets Groups Projects
Commit a391d4fb authored by Kun Yu 【余昆】's avatar Kun Yu 【余昆】 Committed by yefu.chen
Browse files

Fix stuck problem of create_index


Signed-off-by: default avataryukun <kun.yu@zilliz.com>
parent 379e4d5f
No related branches found
No related tags found
No related merge requests found
......@@ -54,12 +54,14 @@ func newRmqMsgStream(ctx context.Context, receiveBufSize int64, rmqBufSize int64
receiveBuf := make(chan *msgstream.MsgPack, receiveBufSize)
consumerChannels := make([]string, 0)
consumerReflects := make([]reflect.SelectCase, 0)
consumers := make([]rocksmq.Consumer, 0)
stream := &RmqMsgStream{
ctx: streamCtx,
receiveBuf: receiveBuf,
unmarshal: unmarshal,
streamCancel: streamCancel,
rmqBufSize: rmqBufSize,
consumers: consumers,
consumerChannels: consumerChannels,
consumerReflects: consumerReflects,
consumerLock: &sync.Mutex{},
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment