[shardingsphere-elasticjob] branch master updated: Replace static method usage in email error handler (#1518)

[zh...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

zhangliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere-elasticjob.git


The following commit(s) were added to refs/heads/master by this push:
     new 3763066  Replace static method usage in email error handler (#1518)
3763066 is described below

commit 376306657276741c0fdd7fa28bb7c37f6e39ad58
Author: 吴伟杰 <ro...@me.com>
AuthorDate: Tue Sep 29 12:59:41 2020 +0800

    Replace static method usage in email error handler (#1518)
---
 .../elasticjob/error/handler/email/EmailJobErrorHandler.java        | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/elasticjob-error-handler/elasticjob-error-handler-email/src/main/java/org/apache/shardingsphere/elasticjob/error/handler/email/EmailJobErrorHandler.java b/elasticjob-error-handler/elasticjob-error-handler-email/src/main/java/org/apache/shardingsphere/elasticjob/error/handler/email/EmailJobErrorHandler.java
index 6a1eb43..83ed800 100644
--- a/elasticjob-error-handler/elasticjob-error-handler-email/src/main/java/org/apache/shardingsphere/elasticjob/error/handler/email/EmailJobErrorHandler.java
+++ b/elasticjob-error-handler/elasticjob-error-handler-email/src/main/java/org/apache/shardingsphere/elasticjob/error/handler/email/EmailJobErrorHandler.java
@@ -28,6 +28,7 @@ import javax.mail.MessagingException;
 import javax.mail.Multipart;
 import javax.mail.PasswordAuthentication;
 import javax.mail.Session;
+import javax.mail.Transport;
 import javax.mail.internet.InternetAddress;
 import javax.mail.internet.MimeBodyPart;
 import javax.mail.internet.MimeMessage;
@@ -115,7 +116,10 @@ public final class EmailJobErrorHandler implements JobErrorHandler {
     }
     
     private void sendMessage(final Message message) throws MessagingException {
-        session.getTransport().send(message);
+        try (Transport transport = session.getTransport()) {
+            transport.connect();
+            transport.sendMessage(message, message.getAllRecipients());
+        }
     }
     
     @Override