From 779c2d89b169d4a4d2bb82205f639d41f381f1d6 Mon Sep 17 00:00:00 2001 From: chenlong Date: Wed, 28 Aug 2024 11:06:37 +0800 Subject: [PATCH] =?UTF-8?q?=E6=A2=A6=E5=A4=A9=E5=A4=B1=E8=B4=A5=E6=8E=A8?= =?UTF-8?q?=E9=80=81BUG=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mt/service/impl/MtOrderLogFailRetryServiceImpl.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/service/impl/MtOrderLogFailRetryServiceImpl.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/service/impl/MtOrderLogFailRetryServiceImpl.java index 67a513c99..33c22fb61 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/service/impl/MtOrderLogFailRetryServiceImpl.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/service/impl/MtOrderLogFailRetryServiceImpl.java @@ -9,6 +9,7 @@ import com.logpm.factory.mt.service.MtOrderLogFailRetryService; import com.logpm.factory.props.MtFactoryProperties; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; +import org.springblade.common.annotations.LogpmAsync; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; @@ -54,7 +55,7 @@ public class MtOrderLogFailRetryServiceImpl implements MtOrderLogFailRetryServic protected final Integer SIGN_TYPE = 6; - @Async + @LogpmAsync("asyncExecutor") @Override public void retry(List waitData){ waitData.forEach(this::executeRetry);