init

fn-rabbitmq/src/main/java/net/yaoyi/pipeline/rabbitmq/RabbitConsumer.java

@@ -20,7 +20,7 @@ public class RabbitConsumer implements PojoRequestHandler<Map<String, Object>, V
 
     private static final String QUEUE_NAME = "vector.search.task.img.dul.check.queue";
 
-    private static final String PIPELINE_API = "http://1861991840278303.eventbridge.cn-beijing-vpc.aliyuncs.com/webhook/putEvents?token=62ed79329bb74d0d8ede5cc5d0487a45897a6ff99f5d4d61946daf9f6e9c7fbc766b9d55ef2241edb2c2cb3aee651ac101409d2783f341aa8e8d27fdb9869d86";
+    private static final String PIPELINE_API = "http://1861991840278303.eventbridge.cn-beijing.aliyuncs.com/webhook/putEvents?token=62ed79329bb74d0d8ede5cc5d0487a45897a6ff99f5d4d61946daf9f6e9c7fbc766b9d55ef2241edb2c2cb3aee651ac101409d2783f341aa8e8d27fdb9869d86";
 
     private static Connection connection;
     private static Channel channel;
@@ -47,7 +47,7 @@ public class RabbitConsumer implements PojoRequestHandler<Map<String, Object>, V
         }
 
         try {
-            Thread.sleep(3000);
+            Thread.sleep(5 * 60 * 1000);
         } catch (InterruptedException e) {
             Thread.currentThread().interrupt();
         }
@@ -99,7 +99,7 @@ public class RabbitConsumer implements PojoRequestHandler<Map<String, Object>, V
                 String responseBody = response.body() != null ? response.body().string() : "";
                 log.info("Pipline API 请求成功:{}", responseBody);
             } else {
-                log.info("Pipline API 请求失败:{}", response.code());
+                log.info("Pipline API 请求失败:{}, body:{}", response.code(), response.body() != null ? response.body().string() : "");
             }
         } catch (Exception e) {
             log.error("Pipline API 请求异常", e);