From 19d0fd2c0e7860e2d5d075f926df0d190ebb34cc Mon Sep 17 00:00:00 2001
From: peternameyakj <908253177@qq.com>
Date: Tue, 15 Oct 2024 10:40:15 +0800
Subject: [PATCH] 邮箱
---
src/main/java/email/sender/EmailServer.java | 22 ++++++++++++++++++----
1 files changed, 18 insertions(+), 4 deletions(-)
diff --git a/src/main/java/email/sender/EmailServer.java b/src/main/java/email/sender/EmailServer.java
index bdc42f7..a60f52e 100644
--- a/src/main/java/email/sender/EmailServer.java
+++ b/src/main/java/email/sender/EmailServer.java
@@ -30,9 +30,15 @@
try {
EmailMessage item = EmailMessageQueue.poll();
-
if (item != null) {
- System.out.println("邮寄地址:" + item.getTomail());
+ System.out.println("邮寄地址111:" + item.getTomail());
+ System.out.println("邮寄地址222:" + item.getSubject());
+ System.out.println("邮寄地址taskExecutor:" + taskExecutor);
+ if(null == taskExecutor){
+ System.out.println("TaskExecutor is not set!");
+ }else {
+ System.out.println("taskExecutor 不是空!");
+ }
taskExecutor.execute(new HandleRunner(item));
}
else {
@@ -53,16 +59,24 @@
private EmailMessage item;
public HandleRunner(EmailMessage item) {
+ System.out.println("t执行到 HandleRunner!");
this.item = item;
}
public void run() {
try {
+ System.out.println("执行HandleRunner的run!");
+ if(null == internalEmailSenderService){
+ System.out.println("internalEmailSenderService is not set!");
+ }else {
+ System.out.println("internalEmailSenderService 不是空!");
+ }
internalEmailSenderService.send(item);
+ System.out.println("HandleRunner的run执行完毕!");
} catch (Throwable t) {
logger.error("EmailServer taskExecutor.execute() fail", t);
}
-
+
}
}
@@ -90,6 +104,6 @@
-
+
}
--
Gitblit v1.9.3