Browse Source

fix(消息队列): 启动异常处理

hejq 7 years ago
parent
commit
31f3cd6fa8

+ 3 - 3
src/main/java/com/uas/platform/b2b/service/impl/PurchaseApCheckServiceImpl.java

@@ -100,7 +100,8 @@ public class PurchaseApCheckServiceImpl implements PurchaseApCheckService {
     private final VendorDao vendorDao;
     private final VendorDao vendorDao;
     private final CommunalLogDao communalLogDao;
     private final CommunalLogDao communalLogDao;
     private final PurcApCheckDao apCheckDao;
     private final PurcApCheckDao apCheckDao;
-    private final ErpProdIODetailService erpProdIODetailService;
+    @Autowired
+    private ErpProdIODetailService erpProdIODetailService;
 
 
     @Resource
     @Resource
     private RabbitSendService rabbitSendService;
     private RabbitSendService rabbitSendService;
@@ -114,7 +115,7 @@ public class PurchaseApCheckServiceImpl implements PurchaseApCheckService {
                                       PurchaseApCheckDoneDao purchaseApCheckDoneDao, PurchaseApCheckItemDao purchaseApCheckItemDao,
                                       PurchaseApCheckDoneDao purchaseApCheckDoneDao, PurchaseApCheckItemDao purchaseApCheckItemDao,
                                       CommonDao commonDao, OrderRedDotService redDotService, EnterpriseDao enterpriseDao,
                                       CommonDao commonDao, OrderRedDotService redDotService, EnterpriseDao enterpriseDao,
                                       UserService userService, VendorDao vendorDao, CommunalLogDao communalLogDao,
                                       UserService userService, VendorDao vendorDao, CommunalLogDao communalLogDao,
-                                      PurcApCheckDao apCheckDao, ErpProdIODetailService erpProdIODetailService) {
+                                      PurcApCheckDao apCheckDao) {
         this.purchaseApCheckDao = purchaseApCheckDao;
         this.purchaseApCheckDao = purchaseApCheckDao;
         this.redDotService = redDotService;
         this.redDotService = redDotService;
         this.purchaseApCheckTodoDao = purchaseApCheckTodoDao;
         this.purchaseApCheckTodoDao = purchaseApCheckTodoDao;
@@ -128,7 +129,6 @@ public class PurchaseApCheckServiceImpl implements PurchaseApCheckService {
         this.apCheckDao = apCheckDao;
         this.apCheckDao = apCheckDao;
         ExecutorService executorService = Executors.newCachedThreadPool();
         ExecutorService executorService = Executors.newCachedThreadPool();
         executor = new BoundedExecutor(executorService, 1600);
         executor = new BoundedExecutor(executorService, 1600);
-        this.erpProdIODetailService = erpProdIODetailService;
     }
     }
 
 
 	@Override
 	@Override

+ 0 - 19
src/main/java/com/uas/platform/b2b/support/mq/RabbitTemplateConfiguration.java

@@ -1,19 +0,0 @@
-package com.uas.platform.b2b.support.mq;
-
-import org.springframework.amqp.rabbit.core.RabbitTemplate;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-
-/**
- * RabbitTemplateConfiguration
- * @author suntg
- * @date 2019-1-15 16:11:42
- */
-@Configuration
-public class RabbitTemplateConfiguration {
-
-    @Bean
-    public RabbitTemplate rabbitTemplate() {
-        return new RabbitTemplate();
-    }
-}