panzhi

 This is because the first send exceeds the set timeout, so it will not continue to retry. I think this restriction should be removed and the timeout should be...

The transaction message review first executes executeLocalTransaction, then there is no commit, and then checkLocalTransaction will be executed all the time

> 另外，在如图位置 > > 无法将自己实现的TransactionListener加入到RocketMQBeanContainerCache，是未扫描到 > 我不清楚spring初始化的具体逻辑 > 我跑的是example > （好像是~Spring cloud~上下文分层的关系 > > debug之后发现只能扫描到这几个bean 这个的原因是TransactionListener 先于RocketMQConfigBeanPostProcessor 初始化了，导致BeanPostProcessor#postProcessAfterInitialization获取不到这个bean，RocketMQBeanContainerCache也就没有了。你可以看下BeanPostProcessor的介绍

Is the maxMessageSize of brokerConfig modified?

compilation fails, do not write Chinese comments

 the new java class need add license，like this

@lijunznb666 ping

Maybe it is caused by too many cached messages. You can check rocketmq_client.log to see if there is a the cached message size exceeds the threshold . PullThresholdSizeForTopic can be...

> So far I've switched to rocketmq-client 4.9.3 and everything works fine without changing any configuration. PullThresholdForTopic and PullThresholdSizeForTopic I tried a variety of, still can appear did not user...

 Look at the call chain here