Commit bf25f113 authored by yanzg's avatar yanzg

接口文档的支持

parent f1d8fa8a
......@@ -26,13 +26,13 @@ public class MqConsumeDynamic {
@Resource
private RabbitAdmin rabbitAdmin;
@Value("${spring.rabbitmq.listener.concurrency:1}")
@Value("${spring.rabbitmq.listener.simple.concurrency:1}")
private int concurrency;
@Value("${spring.rabbitmq.listener.max-concurrency:10}")
@Value("${spring.rabbitmq.listener.simple.max-concurrency:10}")
private int maxConcurrency;
@Value("${spring.rabbitmq.listener.prefetch:100}")
@Value("${spring.rabbitmq.listener.simple.prefetch:100}")
private int prefetch;
@Value("${spring.rabbitmq.listener.transaction-size:100}")
@Value("${spring.rabbitmq.listener.simple.transaction-size:100}")
private int txSize;
public SimpleMessageListenerContainer init(String queueName, ChannelAwareMessageListener messageListener) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment