diff --git a/pom.xml b/pom.xml index 7c0dcb7..77b3ea5 100644 --- a/pom.xml +++ b/pom.xml @@ -322,6 +322,13 @@ spring-boot-starter-amqp + + + javax.annotation + javax.annotation-api + 1.3.2 + + com.github.xiaoymin diff --git a/src/main/java/com/gxwebsoft/common/mq/config/RabbitMQConfig.java b/src/main/java/com/gxwebsoft/common/mq/config/RabbitMQConfig.java index ff2f21d..a910bb5 100644 --- a/src/main/java/com/gxwebsoft/common/mq/config/RabbitMQConfig.java +++ b/src/main/java/com/gxwebsoft/common/mq/config/RabbitMQConfig.java @@ -97,8 +97,8 @@ public class RabbitMQConfig { factory.setConnectionFactory(connectionFactory); factory.setMessageConverter(messageConverter); // 设置并发数 - factory.setConcurrent(1); - factory.setMaxConcurrent(5); + factory.setConcurrentConsumers(1); + factory.setMaxConcurrentConsumers(5); // 设置手动ack factory.setAcknowledgeMode(AcknowledgeMode.MANUAL); // 预取数量