peternameyakj
2024-10-15 19d0fd2c0e7860e2d5d075f926df0d190ebb34cc
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 @@
}