From f7bde8a9d9bf8e3c67c0912cbd8c50fe4f7097aa Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Wed, 13 May 2026 20:17:51 +0800
Subject: [PATCH] 1
---
trading-order-service/src/main/java/com/yami/trading/EmailServer.java | 17 ++++-------------
1 files changed, 4 insertions(+), 13 deletions(-)
diff --git a/trading-order-service/src/main/java/com/yami/trading/EmailServer.java b/trading-order-service/src/main/java/com/yami/trading/EmailServer.java
index 91e1bc6..f8767f1 100644
--- a/trading-order-service/src/main/java/com/yami/trading/EmailServer.java
+++ b/trading-order-service/src/main/java/com/yami/trading/EmailServer.java
@@ -59,28 +59,19 @@
*/
public void run() {
while (true) {
-
try {
EmailMessage item = EmailMessageQueue.poll();
-
- if (item != null) {
- System.out.println("邮寄地址：" + item.getTomail());
- taskExecutor.execute(new HandleRunner(item));
- }
- else {
- /*
- * 限速，最多1秒20个
- */
+ if (null!=item) {
+ logger.info("邮寄地址：" + item.getTomail()+"内容:"+item.getContent());
+ internalEmailSenderService.send(item);
+ }else {
ThreadUtils.sleep(50);
}
-
} catch (Throwable e) {
logger.error("EmailServer taskExecutor.execute() fail", e);
-
}
}
}
-
public class HandleRunner implements Runnable {
private EmailMessage item;
--
Gitblit v1.9.3