Procházet zdrojové kódy

Merge branch 'feature-去掉重复消费' into test

dengsixing před 8 měsíci
rodič
revize
24fcef8b84

+ 3 - 0
src/main/java/com/fdkankan/modeling/receiver/RabbitMqListener.java

@@ -131,6 +131,9 @@ public class RabbitMqListener {
         buildLog.setMessageId(messageId);
         buildLog.setContent(msg);
 
+        //进入计算之前,把上次未关闭的算法杀掉(主要是重启的问题)
+        CreateObjUtil.killMainLoader();
+
         Map<String, Object> ext = buildSceneMessage.getExt();
         if("e57".equals(bizType)){
             this.process4E57(buildSceneMessage,buildLog);