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条回答 默认 最新

报告相同问题？

提交

相关推荐 更多相似问题