Class:
org.apache.rocketmq.spring.starter.RocketMQAutoConfiguration
Method  
registerContainer
Modify:
beanBuilder.addPropertyValue(PROP_CONSUME_THREAD_MAX, 
environment.resolvePlaceholders(annotation.consumeThreadMax()));


Class:
org.apache.rocketmq.spring.starter.annotation.RocketMQMessageListener
Modify:
String consumeThreadMax() default "64"

[ Full content available at: 
https://github.com/apache/rocketmq-externals/issues/124 ]
This message was relayed via gitbox.apache.org for [email protected]

Reply via email to