>
> 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是对死信队列有特殊处理吗？那么我该如何消费死信队列里的消息？？？
>
>
> 谢谢
