向rocketmq队列发送消息，遇到system busy。提示说让进行流控。这是丢入进mq的速度太快吗？理论上不应该啊。
org.apache.rocketmq.client.exception.MQBrokerException: CODE: 2 DESC: [TIMEOUT_CLEAN_QUEUE]broker busy, start flow control for a while, period in queue: 202ms, size of queue: 6
For more information, please visit the url, http://rocketmq.apache.org/docs/faq/
at org.apache.rocketmq.client.impl.MQClientAPIImpl.processSendResponse(MQClientAPIImpl.java:531)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessageSync(MQClientAPIImpl.java:345)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:327)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:290)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendKernelImpl(DefaultMQProducerImpl.java:688)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:458)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1049)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1008)
at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:204)
at com.techcenter.msgqueue.rocketmq.producer.DFProducerPipe.send(DFProducerPipe.java:85)
at com.techcenter.msgqueue.rocketmq.producer.DFProducerPipe.send(DFProducerPipe.java:47)
at com.standardsm.channelapi.filter.YtMobileDeductFilter.deduct(YtMobileDeductFilter.java:105)
at com.standardsm.channelapi.filter.YtMobileDeductFilter.dealObject(YtMobileDeductFilter.java:56)
at com.techcenter.util.chain.SimpleCommand.execute(SimpleCommand.java:20)
at org.apache.commons.chain.impl.ChainBase.execute(ChainBase.java:191)
at com.techcenter.msgqueue.SimpleMsgChain.chainExecute(SimpleMsgChain.java:46)
at com.standardsm.channelapi.listener.YtSmsSubmitTopicListener.onMessage(YtSmsSubmitTopicListener.java:61)
at com.standardsm.channelapi.listener.YtSmsSubmitTopicListener.consumeMessage(YtSmsSubmitTopicListener.java:31)
at org.apache.rocketmq.client.impl.consumer.ConsumeMessageConcurrentlyService$ConsumeRequest.run(ConsumeMessageConcurrentlyService.java:419)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:744)
