正解, 赞👍

> 在 2018年6月5日,下午12:29,卢松 <[email protected]> 写道:
> 
> DLQ的默认读权限是不开的,所以在console上打开DLQ的读权限就可以了
> 
> 在 2018年6月5日 上午9:10,李承霖 <[email protected]> 写道:
>> 
>> 
>> Hi,
>> 
>> 我在代码中声明了一个DefaultMQPushConsumer尝试监听死信队列里的消息,却在代码中获得如下异常
>> 
>> 
>> 08:33:30.588 [RebalanceService] ERROR RocketmqClient -
>> AllocateMessageQueueStrategy.allocate Exception.
>> allocateMessageQueueStrategyName=AVG
>> java.lang.IllegalArgumentException: mqAll is null or mqAll empty
>> at
>> org.apache.rocketmq.client.consumer.rebalance.AllocateMessageQueueAveragely.allocate(AllocateMessageQueueAveragely.java:39)
>> at
>> org.apache.rocketmq.client.impl.consumer.RebalanceImpl.rebalanceByTopic(RebalanceImpl.java:283)
>> at
>> org.apache.rocketmq.client.impl.consumer.RebalanceImpl.doRebalance(RebalanceImpl.java:224)
>> at
>> org.apache.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl.doRebalance(DefaultMQPushConsumerImpl.java:946)
>> at
>> org.apache.rocketmq.client.impl.factory.MQClientInstance.doRebalance(MQClientInstance.java:952)
>> at
>> org.apache.rocketmq.client.impl.consumer.RebalanceService.run(RebalanceService.java:44)
>> at java.lang.Thread.run(Thread.java:748)
>> 
>> 
>> 原因可能是客户端无法找到相应的queue,但我确信死信队列是存在的 且拥有一个QUEUE。
>> 
>> 
>> 除了死信队列外,其他可以正常消费。
>> 
>> Rocket是对死信队列有特殊处理吗?那么我该如何消费死信队列里的消息???
>> 
>> 
>> 谢谢
>> 
>> 

Reply via email to