NSQ记录

 


 

config := nsq.NewConfig()
//最大允许向两台NSQD服务器接受消息,默认是1,要特别注意
config.MaxInFlight=2
c1, err1 := nsq.NewConsumer("test", "test-channel1", nsq.NewConfig()) // 新建一个消费者

 

nsq requeue and backoff