| | |
| | | |
| | | 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 { |
| | |
| | | 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); |
| | | } |
| | | |
| | | |
| | | } |
| | | |
| | | } |
| | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | } |