Commit 1ac30f24 authored by yanzg's avatar yanzg

消费者自动创建

parent a6b4d3a6
...@@ -18,7 +18,7 @@ public class MqConsumeDynamic { ...@@ -18,7 +18,7 @@ public class MqConsumeDynamic {
@Autowired @Autowired
private RabbitAdmin rabbitAdmin; private RabbitAdmin rabbitAdmin;
@Value("${yzg.onOfConsumer}") @Value("${yzg.onOfConsumer:10}")
private int onOfConsumer; private int onOfConsumer;
public SimpleMessageListenerContainer init(String queueName, Object target, String methodName) { public SimpleMessageListenerContainer init(String queueName, Object target, String methodName) {
......
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