dongzexi5125
2019-02-07 19:47
浏览 122
已采纳

如何使用Rabbitmq的一批消息?

Before consuming i set

consumeChannel.Qos(5,0,false)

but still getting only one message, not a pack of five. what i'm doing wrong?

full code:

consumeChannel.Qos(5,0,false)
msgs, _ := consumeChannel.Consume("ticks", "", false, false, false, false, nil, )

for d := range msgs {
    println("Received a message: %s", d.Body)
    println("Done")
    //here will be some extra multiple message handling
    //d.Ack(false)
}

图片转代码服务由CSDN问答提供 功能建议

在我设置之前食用</ p>

  consumeChannel.Qos(5,  0,false)
 </ code> </ pre> 
 
 

,但仍然只收到一条消息,而不是一包5条消息。 我做错了什么?</ p>

完整代码:</ p>

  consumeChannel.Qos(5,0,false)
msgs,_:= ConsumerChannel.Consume(“ ticks”,“”,false,false  ,false,false,nil,)
 
 for d:=范围msgs {
 println(“接收到消息:%s”,d.Body)
 println(“ Done”)
 //此处为 一些额外的多重消息处理
 //d.Ack(false)
}
</ div>

1条回答 默认 最新

相关推荐 更多相似问题