From 9869f39cc82ae584ef4d783bb13316ccd24d26dd Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期五, 17 四月 2026 10:16:47 +0800
Subject: [PATCH] 1
---
zy-asc-conveyor/src/main/java/com/zy/acs/conveyor/core/operation/ConveyorOperationExecutor.java | 26 ++++----------------------
1 files changed, 4 insertions(+), 22 deletions(-)
diff --git a/zy-asc-conveyor/src/main/java/com/zy/acs/conveyor/core/operation/ConveyorOperationExecutor.java b/zy-asc-conveyor/src/main/java/com/zy/acs/conveyor/core/operation/ConveyorOperationExecutor.java
index 85cfb33..7c0fce6 100644
--- a/zy-asc-conveyor/src/main/java/com/zy/acs/conveyor/core/operation/ConveyorOperationExecutor.java
+++ b/zy-asc-conveyor/src/main/java/com/zy/acs/conveyor/core/operation/ConveyorOperationExecutor.java
@@ -32,28 +32,10 @@
News.warn("鏈壘鍒版搷浣滃鐞嗗櫒: {}", config.getType());
return;
}
-
- int retryCount = 0;
- while (retryCount < config.getMaxRetries()) {
- try {
- handler.execute(config);
- return;
- } catch (Exception e) {
- retryCount++;
- if (retryCount >= config.getMaxRetries()) {
- News.error("鎿嶄綔鎵ц澶辫触锛屽凡杈惧埌鏈�澶ч噸璇曟鏁�: {}", config.getType(), e);
- } else {
- News.warn("鎿嶄綔鎵ц澶辫触锛屾鍦ㄩ噸璇�({}/{})",
- retryCount, config.getMaxRetries(), e);
- try {
- Thread.sleep(config.getRetryDelay());
- } catch (InterruptedException ie) {
- Thread.currentThread().interrupt();
- News.error("閲嶈瘯浼戠湢琚腑鏂�", ie);
- return;
- }
- }
- }
+ try {
+ handler.execute(config);
+ } catch (Exception e) {
+ News.error("鎿嶄綔鎵ц澶辫触锛岀瓑寰呬笅涓�鍛ㄦ湡閲嶈瘯: {}", config.getType(), e);
}
}
}
--
Gitblit v1.9.1