Explorar o código

增加计算进度通知

dsx %!s(int64=2) %!d(string=hai) anos
pai
achega
c6d83df5c8

+ 1 - 1
src/main/java/com/fdkankan/contro/mq/listener/BuildSceneProgressListener.java

@@ -41,7 +41,7 @@ public class BuildSceneProgressListener{
         log.info("开始推送场景计算进度,队列名:{},id:{},消息体:{}", queueName, messageId, msg);
         BuildSceneCallMessage buildSceneMessage = JSONObject.parseObject(msg, BuildSceneCallMessage.class);
         buildSceneProgressService.monitorProgress(buildSceneMessage);
-//        channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
+        channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
         log.info("推送场景计算进度完成,队列名:{},id:{},消息体:{}", queueName, messageId, msg);
 
     }

+ 5 - 1
src/main/java/com/fdkankan/contro/mq/service/impl/BuildSceneProgressServiceImpl.java

@@ -138,7 +138,11 @@ public class BuildSceneProgressServiceImpl implements IBuildSceneProgressService
         });
         watchMonitor.start();
 
-        System.out.println();
+        try {
+            Thread.sleep(100000000);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
 
     }