在我消费之前
consumeChannel.Qos(5,0,false)
但仍然只有一条信息,而不是一包五条。
我做错什么了?
完整代码:
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)
}
