关闭重试

sxz-application/src/main/resources/application-dev.properties

@@ -37,7 +37,7 @@ spring.rabbitmq.port=5672
 spring.rabbitmq.username=guest
 spring.rabbitmq.password=guest
 # 开启重试
-spring.rabbitmq.listener.simple.retry.enabled=true
+spring.rabbitmq.listener.simple.retry.enabled=false
 # 重试次数,默认为3次
 spring.rabbitmq.listener.simple.retry.max-attempts=5
 ##mybatis-plus配置 ##

sxz-application/src/main/resources/application-devuat.properties

@@ -37,7 +37,7 @@ spring.rabbitmq.port=5672
 spring.rabbitmq.username=uat
 spring.rabbitmq.password=uat
 # 开启重试
-spring.rabbitmq.listener.simple.retry.enabled=true
+spring.rabbitmq.listener.simple.retry.enabled=false
 # 重试次数,默认为3次
 spring.rabbitmq.listener.simple.retry.max-attempts=5
 ##mybatis-plus配置 ##

sxz-application/src/main/resources/application-prod.properties

@@ -37,7 +37,7 @@ spring.rabbitmq.port=5672
 spring.rabbitmq.username=admin
 spring.rabbitmq.password=sxz12341
 # 开启重试
-spring.rabbitmq.listener.simple.retry.enabled=true
+spring.rabbitmq.listener.simple.retry.enabled=false
 # 重试次数,默认为3次
 spring.rabbitmq.listener.simple.retry.max-attempts=1
 ##mybatis-plus配置 ##

sxz-application/src/main/resources/application-uat.properties

@@ -37,9 +37,9 @@ spring.rabbitmq.port=5672
 spring.rabbitmq.username=guest
 spring.rabbitmq.password=guest
 # 开启重试
-spring.rabbitmq.listener.simple.retry.enabled=true
+spring.rabbitmq.listener.simple.retry.enabled=false
 # 重试次数,默认为3次
-spring.rabbitmq.listener.simple.retry.max-attempts=5
+spring.rabbitmq.listener.simple.retry.max-attempts=1
 ##mybatis-plus配置 ##
 mybatis-plus.configuration.log-impl=org.apache.ibatis.logging.slf4j.Slf4jImpl
 mybatis-plus.configuration.map-underscore-to-camel-case=true

sxz-core/src/main/java/com/fdkk/sxz/other/listener/AddMoldelBuild.java

@@ -79,8 +79,7 @@ public class AddMoldelBuild {
     public void syncModel(Message<RequestRenovationPartsDetailManager> message) {
         AddMoldelBuild.log.info("模型syncmodel：" + message.getPayload() + ",开始同步");
         if (message.getPayload().getQueryType() == 3) {
-            syncModel(message.getPayload());
-
+             syncModel(message.getPayload());
         } else {
             syncModelHandler(message.getPayload());
         }
@@ -183,7 +182,7 @@ public class AddMoldelBuild {
                 modelUploadEntity.setObjSize(param.getObjSize());
                 modelUploadEntity.setImgPath(previewPath);
                 modelUploadService.save(modelUploadEntity);
-
+                return true;
             }
         } catch (Exception e) {
             e.printStackTrace();