generate

src/main/java/com/ai/da/common/RabbitMQ/GenerateConsumer.java

@@ -109,12 +109,18 @@ public class GenerateConsumer {
         long start = System.currentTimeMillis();
 
         Map<String, String> generateResult = JSONObject.parseObject(msg.getBody(), Map.class);
+        // 2.1 手动确认该消息
+        try {
+            channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false);
+        } catch (IOException e) {
+            throw new RuntimeException(e);
+        }
         log.info("tasks_id : {} start ",generateResult.get("tasks_id"));
 //        log.info("tasks_id : {}, message : {}",generateResult.get("tasks_id"), generateResult.get("message") );
         if (generateResult.get("status").equals("SUCCESS")){
             String url = generateResult.get("data");
             String taskId = generateResult.get("tasks_id");
-            generateService.processGenerateResult(taskId, url);
+//            generateService.processGenerateResult(taskId, url);
         }else {
             // 修改redis中的数据状态为exception
             String key = generateResultKey + ":" + generateResult.get("tasks_id");