ed = false;
this.onWaitEnd();
}
}
}
请问,这两种实现的主要区别是什么?有什么特殊要考虑的吗?
有wiki说明这个修改吗?
谢谢!
卢松
best regards
新的queue消费的group能从0开始消费
>
>
>
> --
>
> Have a nice day
>
> Francis Lee
>
>
>
> QQ : 1026203200
>
>
--
best regards
卢松
DLQ的默认读权限是不开的,所以在console上打开DLQ的读权限就可以了
在 2018年6月5日 上午9:10,李承霖 写道:
>
>
> Hi,
>
> 我在代码中声明了一个DefaultMQPushConsumer尝试监听死信队列里的消息,却在代码中获得如下异常
>
>
> 08:33:30.588 [RebalanceService] ERROR RocketmqClient -
> AllocateMessageQueueStrategy.allocate Exception.
> allocateMessageQueueStrategyName=AVG
>