|
|
|
|
@ -65,470 +65,476 @@ import javax.mail.internet.MimeMultipart;
|
|
|
|
|
*/ |
|
|
|
|
public class MailEngine { |
|
|
|
|
|
|
|
|
|
public static Session getSession() { |
|
|
|
|
return getSession(false); |
|
|
|
|
} |
|
|
|
|
public static Session getSession() { |
|
|
|
|
return getSession(false); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
public static Session getSession(Account account) { |
|
|
|
|
Properties properties = _getProperties(account); |
|
|
|
|
public static Session getSession(Account account) { |
|
|
|
|
Properties properties = _getProperties(account); |
|
|
|
|
|
|
|
|
|
Session session = Session.getInstance(properties); |
|
|
|
|
Session session = Session.getInstance(properties); |
|
|
|
|
|
|
|
|
|
if (_log.isDebugEnabled()) { |
|
|
|
|
session.setDebug(true); |
|
|
|
|
if (_log.isDebugEnabled()) { |
|
|
|
|
session.setDebug(true); |
|
|
|
|
|
|
|
|
|
session.getProperties().list(System.out); |
|
|
|
|
} |
|
|
|
|
session.getProperties().list(System.out); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
return session; |
|
|
|
|
} |
|
|
|
|
return session; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
public static Session getSession(boolean cache) { |
|
|
|
|
Session session = null; |
|
|
|
|
public static Session getSession(boolean cache) { |
|
|
|
|
Session session = null; |
|
|
|
|
|
|
|
|
|
try { |
|
|
|
|
session = MailServiceUtil.getSession(); |
|
|
|
|
} catch (SystemException se) { |
|
|
|
|
if (_log.isWarnEnabled()) { |
|
|
|
|
_log.warn(se, se); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
session = InfrastructureUtil.getMailSession(); |
|
|
|
|
} |
|
|
|
|
try { |
|
|
|
|
session = MailServiceUtil.getSession(); |
|
|
|
|
} catch (SystemException se) { |
|
|
|
|
if (_log.isWarnEnabled()) { |
|
|
|
|
_log.warn(se, se); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if (_log.isDebugEnabled()) { |
|
|
|
|
session.setDebug(true); |
|
|
|
|
session = InfrastructureUtil.getMailSession(); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
session.getProperties().list(System.out); |
|
|
|
|
} |
|
|
|
|
if (_log.isDebugEnabled()) { |
|
|
|
|
session.setDebug(true); |
|
|
|
|
|
|
|
|
|
return session; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
public static void send(byte[] bytes) throws MailEngineException { |
|
|
|
|
try { |
|
|
|
|
Session session = getSession(); |
|
|
|
|
session.getProperties().list(System.out); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
Message message = new MimeMessage(session, new UnsyncByteArrayInputStream(bytes)); |
|
|
|
|
return session; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
_send(session, message, null, _BATCH_SIZE); |
|
|
|
|
} catch (Exception e) { |
|
|
|
|
throw new MailEngineException(e); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
public static void send(byte[] bytes) throws MailEngineException { |
|
|
|
|
try { |
|
|
|
|
Session session = getSession(); |
|
|
|
|
|
|
|
|
|
public static void send(InternetAddress from, InternetAddress to, String subject, String body) |
|
|
|
|
throws MailEngineException { |
|
|
|
|
Message message = new MimeMessage(session, new UnsyncByteArrayInputStream(bytes)); |
|
|
|
|
|
|
|
|
|
send(from, new InternetAddress[] {to}, null, null, subject, body, false, null, null, null); |
|
|
|
|
} |
|
|
|
|
_send(session, message, null, _BATCH_SIZE); |
|
|
|
|
} catch (Exception e) { |
|
|
|
|
throw new MailEngineException(e); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
public static void send(InternetAddress from, InternetAddress to, String subject, String body, boolean htmlFormat) |
|
|
|
|
throws MailEngineException { |
|
|
|
|
public static void send(InternetAddress from, InternetAddress to, String subject, String body) |
|
|
|
|
throws MailEngineException { |
|
|
|
|
|
|
|
|
|
send(from, new InternetAddress[] {to}, null, null, subject, body, htmlFormat, null, null, null); |
|
|
|
|
} |
|
|
|
|
send(from, new InternetAddress[] { to }, null, null, subject, body, false, null, null, null); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
public static void send(InternetAddress from, InternetAddress[] to, InternetAddress[] cc, InternetAddress[] bcc, |
|
|
|
|
InternetAddress[] bulkAddresses, String subject, String body, boolean htmlFormat, InternetAddress[] replyTo, |
|
|
|
|
String messageId, String inReplyTo) throws MailEngineException { |
|
|
|
|
public static void send(InternetAddress from, InternetAddress to, String subject, String body, |
|
|
|
|
boolean htmlFormat) throws MailEngineException { |
|
|
|
|
|
|
|
|
|
send(from, to, cc, bcc, bulkAddresses, subject, body, htmlFormat, replyTo, messageId, inReplyTo, null); |
|
|
|
|
} |
|
|
|
|
send(from, new InternetAddress[] { to }, null, null, subject, body, htmlFormat, null, null, null); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
public static void send(InternetAddress from, InternetAddress[] to, InternetAddress[] cc, InternetAddress[] bcc, |
|
|
|
|
InternetAddress[] bulkAddresses, String subject, String body, boolean htmlFormat, InternetAddress[] replyTo, |
|
|
|
|
String messageId, String inReplyTo, List<FileAttachment> fileAttachments) throws MailEngineException { |
|
|
|
|
public static void send(InternetAddress from, InternetAddress[] to, InternetAddress[] cc, |
|
|
|
|
InternetAddress[] bcc, InternetAddress[] bulkAddresses, String subject, String body, |
|
|
|
|
boolean htmlFormat, InternetAddress[] replyTo, String messageId, String inReplyTo) |
|
|
|
|
throws MailEngineException { |
|
|
|
|
|
|
|
|
|
send(from, to, cc, bcc, bulkAddresses, subject, body, htmlFormat, replyTo, messageId, inReplyTo, fileAttachments, |
|
|
|
|
null); |
|
|
|
|
} |
|
|
|
|
send(from, to, cc, bcc, bulkAddresses, subject, body, htmlFormat, replyTo, messageId, inReplyTo, null); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
public static void send(InternetAddress from, InternetAddress[] to, InternetAddress[] cc, InternetAddress[] bcc, |
|
|
|
|
InternetAddress[] bulkAddresses, String subject, String body, boolean htmlFormat, InternetAddress[] replyTo, |
|
|
|
|
String messageId, String inReplyTo, List<FileAttachment> fileAttachments, SMTPAccount smtpAccount) |
|
|
|
|
throws MailEngineException { |
|
|
|
|
public static void send(InternetAddress from, InternetAddress[] to, InternetAddress[] cc, |
|
|
|
|
InternetAddress[] bcc, InternetAddress[] bulkAddresses, String subject, String body, |
|
|
|
|
boolean htmlFormat, InternetAddress[] replyTo, String messageId, String inReplyTo, |
|
|
|
|
List<FileAttachment> fileAttachments) throws MailEngineException { |
|
|
|
|
|
|
|
|
|
long startTime = System.currentTimeMillis(); |
|
|
|
|
send(from, to, cc, bcc, bulkAddresses, subject, body, htmlFormat, replyTo, messageId, inReplyTo, |
|
|
|
|
fileAttachments, null); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if (_log.isDebugEnabled()) { |
|
|
|
|
_log.debug("From: " + from); |
|
|
|
|
_log.debug("To: " + Arrays.toString(to)); |
|
|
|
|
_log.debug("CC: " + Arrays.toString(cc)); |
|
|
|
|
_log.debug("BCC: " + Arrays.toString(bcc)); |
|
|
|
|
_log.debug("List Addresses: " + Arrays.toString(bulkAddresses)); |
|
|
|
|
_log.debug("Subject: " + subject); |
|
|
|
|
_log.debug("Body: " + body); |
|
|
|
|
_log.debug("HTML Format: " + htmlFormat); |
|
|
|
|
_log.debug("Reply to: " + Arrays.toString(replyTo)); |
|
|
|
|
_log.debug("Message ID: " + messageId); |
|
|
|
|
_log.debug("In Reply To: " + inReplyTo); |
|
|
|
|
public static void send(InternetAddress from, InternetAddress[] to, InternetAddress[] cc, |
|
|
|
|
InternetAddress[] bcc, InternetAddress[] bulkAddresses, String subject, String body, |
|
|
|
|
boolean htmlFormat, InternetAddress[] replyTo, String messageId, String inReplyTo, |
|
|
|
|
List<FileAttachment> fileAttachments, SMTPAccount smtpAccount) throws MailEngineException { |
|
|
|
|
|
|
|
|
|
if ((fileAttachments != null) && _log.isDebugEnabled()) { |
|
|
|
|
for (int i = 0; i < fileAttachments.size(); i++) { |
|
|
|
|
|
|
|
|
|
FileAttachment fileAttachment = fileAttachments.get(i); |
|
|
|
|
if (fileAttachment instanceof it.tref.liferay.portos.mailmanager.shared.model.FileAttachment) { |
|
|
|
|
((it.tref.liferay.portos.mailmanager.shared.model.FileAttachment) fileAttachment).generateFile(); |
|
|
|
|
} |
|
|
|
|
File file = fileAttachment.getFile(); |
|
|
|
|
long startTime = System.currentTimeMillis(); |
|
|
|
|
|
|
|
|
|
if (file == null) { |
|
|
|
|
continue; |
|
|
|
|
} |
|
|
|
|
if (_log.isDebugEnabled()) { |
|
|
|
|
_log.debug("From: " + from); |
|
|
|
|
_log.debug("To: " + Arrays.toString(to)); |
|
|
|
|
_log.debug("CC: " + Arrays.toString(cc)); |
|
|
|
|
_log.debug("BCC: " + Arrays.toString(bcc)); |
|
|
|
|
_log.debug("List Addresses: " + Arrays.toString(bulkAddresses)); |
|
|
|
|
_log.debug("Subject: " + subject); |
|
|
|
|
_log.debug("Body: " + body); |
|
|
|
|
_log.debug("HTML Format: " + htmlFormat); |
|
|
|
|
_log.debug("Reply to: " + Arrays.toString(replyTo)); |
|
|
|
|
_log.debug("Message ID: " + messageId); |
|
|
|
|
_log.debug("In Reply To: " + inReplyTo); |
|
|
|
|
|
|
|
|
|
_log.debug("Attachment " + i + " file " + file.getAbsolutePath() + " and file name " |
|
|
|
|
+ fileAttachment.getFileName()); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
if ((fileAttachments != null) && _log.isDebugEnabled()) { |
|
|
|
|
for (int i = 0; i < fileAttachments.size(); i++) { |
|
|
|
|
|
|
|
|
|
try { |
|
|
|
|
InternetAddressUtil.validateAddress(from); |
|
|
|
|
FileAttachment fileAttachment = fileAttachments.get(i); |
|
|
|
|
if (fileAttachment instanceof it.tref.liferay.portos.mailmanager.shared.model.FileAttachment) { |
|
|
|
|
((it.tref.liferay.portos.mailmanager.shared.model.FileAttachment) fileAttachment) |
|
|
|
|
.generateFile(); |
|
|
|
|
} |
|
|
|
|
File file = fileAttachment.getFile(); |
|
|
|
|
|
|
|
|
|
if (ArrayUtil.isNotEmpty(to)) { |
|
|
|
|
InternetAddressUtil.validateAddresses(to); |
|
|
|
|
} |
|
|
|
|
if (file == null) { |
|
|
|
|
continue; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if (ArrayUtil.isNotEmpty(cc)) { |
|
|
|
|
InternetAddressUtil.validateAddresses(cc); |
|
|
|
|
} |
|
|
|
|
_log.debug("Attachment " + i + " file " + file.getAbsolutePath() + " and file name " |
|
|
|
|
+ fileAttachment.getFileName()); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if (ArrayUtil.isNotEmpty(bcc)) { |
|
|
|
|
InternetAddressUtil.validateAddresses(bcc); |
|
|
|
|
} |
|
|
|
|
try { |
|
|
|
|
InternetAddressUtil.validateAddress(from); |
|
|
|
|
|
|
|
|
|
if (ArrayUtil.isNotEmpty(replyTo)) { |
|
|
|
|
InternetAddressUtil.validateAddresses(replyTo); |
|
|
|
|
} |
|
|
|
|
if (ArrayUtil.isNotEmpty(to)) { |
|
|
|
|
InternetAddressUtil.validateAddresses(to); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if (ArrayUtil.isNotEmpty(bulkAddresses)) { |
|
|
|
|
InternetAddressUtil.validateAddresses(bulkAddresses); |
|
|
|
|
} |
|
|
|
|
if (ArrayUtil.isNotEmpty(cc)) { |
|
|
|
|
InternetAddressUtil.validateAddresses(cc); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
Session session = null; |
|
|
|
|
if (ArrayUtil.isNotEmpty(bcc)) { |
|
|
|
|
InternetAddressUtil.validateAddresses(bcc); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if (smtpAccount == null) { |
|
|
|
|
session = getSession(); |
|
|
|
|
} else { |
|
|
|
|
session = getSession(smtpAccount); |
|
|
|
|
} |
|
|
|
|
if (ArrayUtil.isNotEmpty(replyTo)) { |
|
|
|
|
InternetAddressUtil.validateAddresses(replyTo); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
Message message = new LiferayMimeMessage(session); |
|
|
|
|
if (ArrayUtil.isNotEmpty(bulkAddresses)) { |
|
|
|
|
InternetAddressUtil.validateAddresses(bulkAddresses); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
message.addHeader("X-Auto-Response-Suppress", "AutoReply, DR, NDR, NRN, OOF, RN"); |
|
|
|
|
Session session = null; |
|
|
|
|
|
|
|
|
|
message.setFrom(from); |
|
|
|
|
if (smtpAccount == null) { |
|
|
|
|
session = getSession(); |
|
|
|
|
} else { |
|
|
|
|
session = getSession(smtpAccount); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if (ArrayUtil.isNotEmpty(to)) { |
|
|
|
|
message.setRecipients(Message.RecipientType.TO, to); |
|
|
|
|
} |
|
|
|
|
Message message = new LiferayMimeMessage(session); |
|
|
|
|
|
|
|
|
|
if (ArrayUtil.isNotEmpty(cc)) { |
|
|
|
|
message.setRecipients(Message.RecipientType.CC, cc); |
|
|
|
|
} |
|
|
|
|
message.addHeader("X-Auto-Response-Suppress", "AutoReply, DR, NDR, NRN, OOF, RN"); |
|
|
|
|
|
|
|
|
|
if (ArrayUtil.isNotEmpty(bcc)) { |
|
|
|
|
message.setRecipients(Message.RecipientType.BCC, bcc); |
|
|
|
|
} |
|
|
|
|
message.setFrom(from); |
|
|
|
|
|
|
|
|
|
subject = GetterUtil.getString(subject); |
|
|
|
|
if (ArrayUtil.isNotEmpty(to)) { |
|
|
|
|
message.setRecipients(Message.RecipientType.TO, to); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
message.setSubject(subject); |
|
|
|
|
if (ArrayUtil.isNotEmpty(cc)) { |
|
|
|
|
message.setRecipients(Message.RecipientType.CC, cc); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if ((fileAttachments != null) && (fileAttachments.size() > 0)) { |
|
|
|
|
MimeMultipart rootMultipart = new MimeMultipart(_MULTIPART_TYPE_MIXED); |
|
|
|
|
if (ArrayUtil.isNotEmpty(bcc)) { |
|
|
|
|
message.setRecipients(Message.RecipientType.BCC, bcc); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
MimeMultipart messageMultipart = new MimeMultipart(_MULTIPART_TYPE_ALTERNATIVE); |
|
|
|
|
subject = GetterUtil.getString(subject); |
|
|
|
|
|
|
|
|
|
MimeBodyPart messageBodyPart = new MimeBodyPart(); |
|
|
|
|
message.setSubject(subject); |
|
|
|
|
|
|
|
|
|
messageBodyPart.setContent(messageMultipart); |
|
|
|
|
if ((fileAttachments != null) && (fileAttachments.size() > 0)) { |
|
|
|
|
MimeMultipart rootMultipart = new MimeMultipart(_MULTIPART_TYPE_MIXED); |
|
|
|
|
|
|
|
|
|
rootMultipart.addBodyPart(messageBodyPart); |
|
|
|
|
MimeMultipart messageMultipart = new MimeMultipart(_MULTIPART_TYPE_ALTERNATIVE); |
|
|
|
|
|
|
|
|
|
if (htmlFormat) { |
|
|
|
|
MimeBodyPart bodyPart = new MimeBodyPart(); |
|
|
|
|
MimeBodyPart messageBodyPart = new MimeBodyPart(); |
|
|
|
|
|
|
|
|
|
bodyPart.setContent(body, _TEXT_HTML); |
|
|
|
|
messageBodyPart.setContent(messageMultipart); |
|
|
|
|
|
|
|
|
|
messageMultipart.addBodyPart(bodyPart); |
|
|
|
|
} else { |
|
|
|
|
MimeBodyPart bodyPart = new MimeBodyPart(); |
|
|
|
|
rootMultipart.addBodyPart(messageBodyPart); |
|
|
|
|
|
|
|
|
|
bodyPart.setText(body); |
|
|
|
|
if (htmlFormat) { |
|
|
|
|
MimeBodyPart bodyPart = new MimeBodyPart(); |
|
|
|
|
|
|
|
|
|
messageMultipart.addBodyPart(bodyPart); |
|
|
|
|
} |
|
|
|
|
bodyPart.setContent(body, _TEXT_HTML); |
|
|
|
|
|
|
|
|
|
for (int i = 0; i < fileAttachments.size(); i++) { |
|
|
|
|
FileAttachment fileAttachment = fileAttachments.get(i); |
|
|
|
|
messageMultipart.addBodyPart(bodyPart); |
|
|
|
|
} else { |
|
|
|
|
MimeBodyPart bodyPart = new MimeBodyPart(); |
|
|
|
|
|
|
|
|
|
File file = fileAttachment.getFile(); |
|
|
|
|
bodyPart.setText(body); |
|
|
|
|
|
|
|
|
|
if (file == null) { |
|
|
|
|
continue; |
|
|
|
|
} |
|
|
|
|
messageMultipart.addBodyPart(bodyPart); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
MimeBodyPart mimeBodyPart = new MimeBodyPart(); |
|
|
|
|
for (int i = 0; i < fileAttachments.size(); i++) { |
|
|
|
|
FileAttachment fileAttachment = fileAttachments.get(i); |
|
|
|
|
|
|
|
|
|
DataSource dataSource = new FileDataSource(file); |
|
|
|
|
File file = fileAttachment.getFile(); |
|
|
|
|
|
|
|
|
|
mimeBodyPart.setDataHandler(new DataHandler(dataSource)); |
|
|
|
|
mimeBodyPart.setDisposition(Part.ATTACHMENT); |
|
|
|
|
if (file == null) { |
|
|
|
|
continue; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if (fileAttachment.getFileName() != null) { |
|
|
|
|
mimeBodyPart.setFileName(fileAttachment.getFileName()); |
|
|
|
|
} else { |
|
|
|
|
mimeBodyPart.setFileName(file.getName()); |
|
|
|
|
} |
|
|
|
|
MimeBodyPart mimeBodyPart = new MimeBodyPart(); |
|
|
|
|
|
|
|
|
|
rootMultipart.addBodyPart(mimeBodyPart); |
|
|
|
|
} |
|
|
|
|
DataSource dataSource = new FileDataSource(file); |
|
|
|
|
|
|
|
|
|
message.setContent(rootMultipart); |
|
|
|
|
mimeBodyPart.setDataHandler(new DataHandler(dataSource)); |
|
|
|
|
mimeBodyPart.setDisposition(Part.ATTACHMENT); |
|
|
|
|
|
|
|
|
|
message.saveChanges(); |
|
|
|
|
} else { |
|
|
|
|
if (htmlFormat) { |
|
|
|
|
message.setContent(body, _TEXT_HTML); |
|
|
|
|
} else { |
|
|
|
|
message.setContent(body, _TEXT_PLAIN); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
if (fileAttachment.getFileName() != null) { |
|
|
|
|
mimeBodyPart.setFileName(fileAttachment.getFileName()); |
|
|
|
|
} else { |
|
|
|
|
mimeBodyPart.setFileName(file.getName()); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
message.setSentDate(new Date()); |
|
|
|
|
rootMultipart.addBodyPart(mimeBodyPart); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if (ArrayUtil.isNotEmpty(replyTo)) { |
|
|
|
|
message.setReplyTo(replyTo); |
|
|
|
|
} |
|
|
|
|
message.setContent(rootMultipart); |
|
|
|
|
|
|
|
|
|
if (messageId != null) { |
|
|
|
|
message.setHeader("Message-ID", messageId); |
|
|
|
|
} |
|
|
|
|
message.saveChanges(); |
|
|
|
|
} else { |
|
|
|
|
if (htmlFormat) { |
|
|
|
|
message.setContent(body, _TEXT_HTML); |
|
|
|
|
} else { |
|
|
|
|
message.setContent(body, _TEXT_PLAIN); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if (inReplyTo != null) { |
|
|
|
|
message.setHeader("In-Reply-To", inReplyTo); |
|
|
|
|
message.setHeader("References", inReplyTo); |
|
|
|
|
} |
|
|
|
|
message.setSentDate(new Date()); |
|
|
|
|
|
|
|
|
|
int batchSize = GetterUtil.getInteger(PropsUtil.get(PropsKeys.MAIL_BATCH_SIZE), _BATCH_SIZE); |
|
|
|
|
if (ArrayUtil.isNotEmpty(replyTo)) { |
|
|
|
|
message.setReplyTo(replyTo); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
_send(session, message, bulkAddresses, batchSize); |
|
|
|
|
} catch (SendFailedException sfe) { |
|
|
|
|
_log.error(sfe); |
|
|
|
|
if (messageId != null) { |
|
|
|
|
message.setHeader("Message-ID", messageId); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
// if (_isThrowsExceptionOnFailure()) {
|
|
|
|
|
// throw new MailEngineException(sfe);
|
|
|
|
|
// }
|
|
|
|
|
throw new MailEngineException(sfe); |
|
|
|
|
} catch (Exception e) { |
|
|
|
|
throw new MailEngineException(e); |
|
|
|
|
} |
|
|
|
|
if (inReplyTo != null) { |
|
|
|
|
message.setHeader("In-Reply-To", inReplyTo); |
|
|
|
|
message.setHeader("References", inReplyTo); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if (_log.isDebugEnabled()) { |
|
|
|
|
_log.debug("Sending mail takes " + (System.currentTimeMillis() - startTime) + " ms"); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
int batchSize = GetterUtil.getInteger(PropsUtil.get(PropsKeys.MAIL_BATCH_SIZE), _BATCH_SIZE); |
|
|
|
|
|
|
|
|
|
public static void send(InternetAddress from, InternetAddress[] to, InternetAddress[] cc, InternetAddress[] bcc, |
|
|
|
|
String subject, String body) throws MailEngineException { |
|
|
|
|
_send(session, message, bulkAddresses, batchSize); |
|
|
|
|
} catch (SendFailedException sfe) { |
|
|
|
|
_log.error(sfe); |
|
|
|
|
|
|
|
|
|
send(from, to, cc, bcc, subject, body, false, null, null, null); |
|
|
|
|
} |
|
|
|
|
// if (_isThrowsExceptionOnFailure()) {
|
|
|
|
|
// throw new MailEngineException(sfe);
|
|
|
|
|
// }
|
|
|
|
|
throw new MailEngineException(sfe); |
|
|
|
|
} catch (Exception e) { |
|
|
|
|
throw new MailEngineException(e); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
public static void send(InternetAddress from, InternetAddress[] to, InternetAddress[] cc, InternetAddress[] bcc, |
|
|
|
|
String subject, String body, boolean htmlFormat, InternetAddress[] replyTo, String messageId, String inReplyTo) |
|
|
|
|
throws MailEngineException { |
|
|
|
|
if (_log.isDebugEnabled()) { |
|
|
|
|
_log.debug("Sending mail takes " + (System.currentTimeMillis() - startTime) + " ms"); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
send(from, to, cc, bcc, null, subject, body, htmlFormat, replyTo, messageId, inReplyTo, null); |
|
|
|
|
} |
|
|
|
|
public static void send(InternetAddress from, InternetAddress[] to, InternetAddress[] cc, |
|
|
|
|
InternetAddress[] bcc, String subject, String body) throws MailEngineException { |
|
|
|
|
|
|
|
|
|
public static void |
|
|
|
|
send(InternetAddress from, InternetAddress[] to, InternetAddress[] cc, String subject, String body) |
|
|
|
|
throws MailEngineException { |
|
|
|
|
send(from, to, cc, bcc, subject, body, false, null, null, null); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
send(from, to, cc, null, subject, body, false, null, null, null); |
|
|
|
|
} |
|
|
|
|
public static void send(InternetAddress from, InternetAddress[] to, InternetAddress[] cc, |
|
|
|
|
InternetAddress[] bcc, String subject, String body, boolean htmlFormat, |
|
|
|
|
InternetAddress[] replyTo, String messageId, String inReplyTo) throws MailEngineException { |
|
|
|
|
|
|
|
|
|
public static void send(InternetAddress from, InternetAddress[] to, InternetAddress[] cc, String subject, |
|
|
|
|
String body, boolean htmlFormat) throws MailEngineException { |
|
|
|
|
send(from, to, cc, bcc, null, subject, body, htmlFormat, replyTo, messageId, inReplyTo, null); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
send(from, to, cc, null, subject, body, htmlFormat, null, null, null); |
|
|
|
|
} |
|
|
|
|
public static void send(InternetAddress from, InternetAddress[] to, InternetAddress[] cc, String subject, |
|
|
|
|
String body) throws MailEngineException { |
|
|
|
|
|
|
|
|
|
public static void send(InternetAddress from, InternetAddress[] to, String subject, String body) |
|
|
|
|
throws MailEngineException { |
|
|
|
|
send(from, to, cc, null, subject, body, false, null, null, null); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
send(from, to, null, null, subject, body, false, null, null, null); |
|
|
|
|
} |
|
|
|
|
public static void send(InternetAddress from, InternetAddress[] to, InternetAddress[] cc, String subject, |
|
|
|
|
String body, boolean htmlFormat) throws MailEngineException { |
|
|
|
|
|
|
|
|
|
public static void send(InternetAddress from, InternetAddress[] to, String subject, String body, boolean htmlFormat) |
|
|
|
|
throws MailEngineException { |
|
|
|
|
send(from, to, cc, null, subject, body, htmlFormat, null, null, null); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
send(from, to, null, null, subject, body, htmlFormat, null, null, null); |
|
|
|
|
} |
|
|
|
|
public static void send(InternetAddress from, InternetAddress[] to, String subject, String body) |
|
|
|
|
throws MailEngineException { |
|
|
|
|
|
|
|
|
|
public static void send(MailMessage mailMessage) throws MailEngineException { |
|
|
|
|
send(from, to, null, null, subject, body, false, null, null, null); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
send(mailMessage.getFrom(), mailMessage.getTo(), mailMessage.getCC(), mailMessage.getBCC(), mailMessage |
|
|
|
|
.getBulkAddresses(), mailMessage.getSubject(), mailMessage.getBody(), mailMessage.isHTMLFormat(), mailMessage |
|
|
|
|
.getReplyTo(), mailMessage.getMessageId(), mailMessage.getInReplyTo(), mailMessage.getFileAttachments(), |
|
|
|
|
mailMessage.getSMTPAccount()); |
|
|
|
|
} |
|
|
|
|
public static void send(InternetAddress from, InternetAddress[] to, String subject, String body, |
|
|
|
|
boolean htmlFormat) throws MailEngineException { |
|
|
|
|
|
|
|
|
|
public static void send(String from, String to, String subject, String body) throws MailEngineException { |
|
|
|
|
send(from, to, null, null, subject, body, htmlFormat, null, null, null); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
try { |
|
|
|
|
send(new InternetAddress(from), new InternetAddress(to), subject, body); |
|
|
|
|
} catch (AddressException ae) { |
|
|
|
|
throw new MailEngineException(ae); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
public static void send(MailMessage mailMessage) throws MailEngineException { |
|
|
|
|
|
|
|
|
|
private static Address[] _getBatchAddresses(Address[] addresses, int index, int batchSize) { |
|
|
|
|
send(mailMessage.getFrom(), mailMessage.getTo(), mailMessage.getCC(), mailMessage.getBCC(), |
|
|
|
|
mailMessage.getBulkAddresses(), mailMessage.getSubject(), mailMessage.getBody(), |
|
|
|
|
mailMessage.isHTMLFormat(), mailMessage.getReplyTo(), mailMessage.getMessageId(), |
|
|
|
|
mailMessage.getInReplyTo(), mailMessage.getFileAttachments(), mailMessage.getSMTPAccount()); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if ((batchSize == _BATCH_SIZE) && (index == 0)) { |
|
|
|
|
return addresses; |
|
|
|
|
} else if (batchSize == _BATCH_SIZE) { |
|
|
|
|
return null; |
|
|
|
|
} |
|
|
|
|
public static void send(String from, String to, String subject, String body) throws MailEngineException { |
|
|
|
|
|
|
|
|
|
int start = index * batchSize; |
|
|
|
|
try { |
|
|
|
|
send(new InternetAddress(from), new InternetAddress(to), subject, body); |
|
|
|
|
} catch (AddressException ae) { |
|
|
|
|
throw new MailEngineException(ae); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if (start > addresses.length) { |
|
|
|
|
return null; |
|
|
|
|
} |
|
|
|
|
private static Address[] _getBatchAddresses(Address[] addresses, int index, int batchSize) { |
|
|
|
|
|
|
|
|
|
int end = ((index + 1) * batchSize); |
|
|
|
|
if ((batchSize == _BATCH_SIZE) && (index == 0)) { |
|
|
|
|
return addresses; |
|
|
|
|
} else if (batchSize == _BATCH_SIZE) { |
|
|
|
|
return null; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if (end > addresses.length) { |
|
|
|
|
end = addresses.length; |
|
|
|
|
} |
|
|
|
|
int start = index * batchSize; |
|
|
|
|
|
|
|
|
|
return ArrayUtil.subset(addresses, start, end); |
|
|
|
|
} |
|
|
|
|
if (start > addresses.length) { |
|
|
|
|
return null; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private static Properties _getProperties(Account account) { |
|
|
|
|
Properties properties = new Properties(); |
|
|
|
|
int end = ((index + 1) * batchSize); |
|
|
|
|
|
|
|
|
|
String protocol = account.getProtocol(); |
|
|
|
|
if (end > addresses.length) { |
|
|
|
|
end = addresses.length; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
properties.setProperty("mail.transport.protocol", protocol); |
|
|
|
|
properties.setProperty("mail." + protocol + ".host", account.getHost()); |
|
|
|
|
properties.setProperty("mail." + protocol + ".port", String.valueOf(account.getPort())); |
|
|
|
|
return ArrayUtil.subset(addresses, start, end); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if (account.isRequiresAuthentication()) { |
|
|
|
|
properties.setProperty("mail." + protocol + ".auth", "true"); |
|
|
|
|
properties.setProperty("mail." + protocol + ".user", account.getUser()); |
|
|
|
|
properties.setProperty("mail." + protocol + ".password", account.getPassword()); |
|
|
|
|
} |
|
|
|
|
private static Properties _getProperties(Account account) { |
|
|
|
|
Properties properties = new Properties(); |
|
|
|
|
|
|
|
|
|
if (account.isSecure()) { |
|
|
|
|
properties.setProperty("mail." + protocol + ".socketFactory.class", "javax.net.ssl.SSLSocketFactory"); |
|
|
|
|
properties.setProperty("mail." + protocol + ".socketFactory.fallback", "false"); |
|
|
|
|
properties.setProperty("mail." + protocol + ".socketFactory.port", String.valueOf(account.getPort())); |
|
|
|
|
} |
|
|
|
|
String protocol = account.getProtocol(); |
|
|
|
|
|
|
|
|
|
return properties; |
|
|
|
|
} |
|
|
|
|
properties.setProperty("mail.transport.protocol", protocol); |
|
|
|
|
properties.setProperty("mail." + protocol + ".host", account.getHost()); |
|
|
|
|
properties.setProperty("mail." + protocol + ".port", String.valueOf(account.getPort())); |
|
|
|
|
|
|
|
|
|
private static String _getSMTPProperty(Session session, String suffix) { |
|
|
|
|
String protocol = GetterUtil.getString(session.getProperty("mail.transport.protocol")); |
|
|
|
|
if (account.isRequiresAuthentication()) { |
|
|
|
|
properties.setProperty("mail." + protocol + ".auth", "true"); |
|
|
|
|
properties.setProperty("mail." + protocol + ".user", account.getUser()); |
|
|
|
|
properties.setProperty("mail." + protocol + ".password", account.getPassword()); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if (protocol.equals(Account.PROTOCOL_SMTPS)) { |
|
|
|
|
return session.getProperty("mail.smtps." + suffix); |
|
|
|
|
} else { |
|
|
|
|
return session.getProperty("mail.smtp." + suffix); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
if (account.isSecure()) { |
|
|
|
|
properties.setProperty("mail." + protocol + ".socketFactory.class", |
|
|
|
|
"javax.net.ssl.SSLSocketFactory"); |
|
|
|
|
properties.setProperty("mail." + protocol + ".socketFactory.fallback", "false"); |
|
|
|
|
properties.setProperty("mail." + protocol + ".socketFactory.port", |
|
|
|
|
String.valueOf(account.getPort())); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
// private static boolean _isThrowsExceptionOnFailure() {
|
|
|
|
|
// return GetterUtil.getBoolean(PropsUtil.get(PropsKeys.MAIL_THROWS_EXCEPTION_ON_FAILURE));
|
|
|
|
|
// }
|
|
|
|
|
return properties; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private static void _send(Session session, Message message, InternetAddress[] bulkAddresses, int batchSize) |
|
|
|
|
throws MailEngineException { |
|
|
|
|
private static String _getSMTPProperty(Session session, String suffix) { |
|
|
|
|
String protocol = GetterUtil.getString(session.getProperty("mail.transport.protocol")); |
|
|
|
|
|
|
|
|
|
try { |
|
|
|
|
boolean smtpAuth = GetterUtil.getBoolean(_getSMTPProperty(session, "auth"), false); |
|
|
|
|
String smtpHost = _getSMTPProperty(session, "host"); |
|
|
|
|
int smtpPort = GetterUtil.getInteger(_getSMTPProperty(session, "port"), Account.PORT_SMTP); |
|
|
|
|
String user = _getSMTPProperty(session, "user"); |
|
|
|
|
String password = _getSMTPProperty(session, "password"); |
|
|
|
|
if (protocol.equals(Account.PROTOCOL_SMTPS)) { |
|
|
|
|
return session.getProperty("mail.smtps." + suffix); |
|
|
|
|
} else { |
|
|
|
|
return session.getProperty("mail.smtp." + suffix); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if (smtpAuth && Validator.isNotNull(user) && Validator.isNotNull(password)) { |
|
|
|
|
// private static boolean _isThrowsExceptionOnFailure() {
|
|
|
|
|
// return
|
|
|
|
|
// GetterUtil.getBoolean(PropsUtil.get(PropsKeys.MAIL_THROWS_EXCEPTION_ON_FAILURE));
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
String protocol = GetterUtil.getString(session.getProperty("mail.transport.protocol"), Account.PROTOCOL_SMTP); |
|
|
|
|
private static void _send(Session session, Message message, InternetAddress[] bulkAddresses, int batchSize) |
|
|
|
|
throws MailEngineException { |
|
|
|
|
|
|
|
|
|
Transport transport = session.getTransport(protocol); |
|
|
|
|
try { |
|
|
|
|
boolean smtpAuth = GetterUtil.getBoolean(_getSMTPProperty(session, "auth"), false); |
|
|
|
|
String smtpHost = _getSMTPProperty(session, "host"); |
|
|
|
|
int smtpPort = GetterUtil.getInteger(_getSMTPProperty(session, "port"), Account.PORT_SMTP); |
|
|
|
|
String user = _getSMTPProperty(session, "user"); |
|
|
|
|
String password = _getSMTPProperty(session, "password"); |
|
|
|
|
|
|
|
|
|
transport.connect(smtpHost, smtpPort, user, password); |
|
|
|
|
if (smtpAuth && Validator.isNotNull(user) && Validator.isNotNull(password)) { |
|
|
|
|
|
|
|
|
|
Address[] addresses = null; |
|
|
|
|
String protocol = GetterUtil.getString(session.getProperty("mail.transport.protocol"), |
|
|
|
|
Account.PROTOCOL_SMTP); |
|
|
|
|
|
|
|
|
|
if (ArrayUtil.isNotEmpty(bulkAddresses)) { |
|
|
|
|
addresses = bulkAddresses; |
|
|
|
|
} else { |
|
|
|
|
addresses = message.getAllRecipients(); |
|
|
|
|
} |
|
|
|
|
Transport transport = session.getTransport(protocol); |
|
|
|
|
|
|
|
|
|
for (int i = 0;; i++) { |
|
|
|
|
Address[] batchAddresses = _getBatchAddresses(addresses, i, batchSize); |
|
|
|
|
transport.connect(smtpHost, smtpPort, user, password); |
|
|
|
|
|
|
|
|
|
if (ArrayUtil.isEmpty(batchAddresses)) { |
|
|
|
|
break; |
|
|
|
|
} |
|
|
|
|
Address[] addresses = null; |
|
|
|
|
|
|
|
|
|
transport.sendMessage(message, batchAddresses); |
|
|
|
|
} |
|
|
|
|
if (ArrayUtil.isNotEmpty(bulkAddresses)) { |
|
|
|
|
addresses = bulkAddresses; |
|
|
|
|
} else { |
|
|
|
|
addresses = message.getAllRecipients(); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
transport.close(); |
|
|
|
|
} else { |
|
|
|
|
if (ArrayUtil.isNotEmpty(bulkAddresses)) { |
|
|
|
|
int curBatch = 0; |
|
|
|
|
for (int i = 0;; i++) { |
|
|
|
|
Address[] batchAddresses = _getBatchAddresses(addresses, i, batchSize); |
|
|
|
|
|
|
|
|
|
Address[] portion = _getBatchAddresses(bulkAddresses, curBatch, batchSize); |
|
|
|
|
if (ArrayUtil.isEmpty(batchAddresses)) { |
|
|
|
|
break; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
while (ArrayUtil.isNotEmpty(portion)) { |
|
|
|
|
Transport.send(message, portion); |
|
|
|
|
transport.sendMessage(message, batchAddresses); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
curBatch++; |
|
|
|
|
transport.close(); |
|
|
|
|
} else { |
|
|
|
|
if (ArrayUtil.isNotEmpty(bulkAddresses)) { |
|
|
|
|
int curBatch = 0; |
|
|
|
|
|
|
|
|
|
portion = _getBatchAddresses(bulkAddresses, curBatch, batchSize); |
|
|
|
|
} |
|
|
|
|
} else { |
|
|
|
|
Transport.send(message); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} catch (MessagingException me) { |
|
|
|
|
if (me.getNextException() instanceof SocketException) { |
|
|
|
|
if (_log.isWarnEnabled()) { |
|
|
|
|
_log.warn("Failed to connect to a valid mail server. Please " + "make sure one is properly configured. " |
|
|
|
|
+ me.getMessage()); |
|
|
|
|
} |
|
|
|
|
} else { |
|
|
|
|
LogUtil.log(_log, me); |
|
|
|
|
} |
|
|
|
|
Address[] portion = _getBatchAddresses(bulkAddresses, curBatch, batchSize); |
|
|
|
|
|
|
|
|
|
// if (_isThrowsExceptionOnFailure()) {
|
|
|
|
|
// throw new MailEngineException(me);
|
|
|
|
|
// }
|
|
|
|
|
while (ArrayUtil.isNotEmpty(portion)) { |
|
|
|
|
Transport.send(message, portion); |
|
|
|
|
|
|
|
|
|
throw new MailEngineException(me); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
curBatch++; |
|
|
|
|
|
|
|
|
|
private static final int _BATCH_SIZE = 0; |
|
|
|
|
portion = _getBatchAddresses(bulkAddresses, curBatch, batchSize); |
|
|
|
|
} |
|
|
|
|
} else { |
|
|
|
|
Transport.send(message); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} catch (MessagingException me) { |
|
|
|
|
if (me.getNextException() instanceof SocketException) { |
|
|
|
|
if (_log.isWarnEnabled()) { |
|
|
|
|
_log.warn("Failed to connect to a valid mail server. Please " |
|
|
|
|
+ "make sure one is properly configured. " + me.getMessage()); |
|
|
|
|
} |
|
|
|
|
} else { |
|
|
|
|
LogUtil.log(_log, me); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private static final String _MULTIPART_TYPE_ALTERNATIVE = "alternative"; |
|
|
|
|
// if (_isThrowsExceptionOnFailure()) {
|
|
|
|
|
// throw new MailEngineException(me);
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
private static final String _MULTIPART_TYPE_MIXED = "mixed"; |
|
|
|
|
throw new MailEngineException(me); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private static final String _TEXT_HTML = "text/html;charset=\"UTF-8\""; |
|
|
|
|
private static final int _BATCH_SIZE = 0; |
|
|
|
|
|
|
|
|
|
private static final String _TEXT_PLAIN = "text/plain;charset=\"UTF-8\""; |
|
|
|
|
private static final String _MULTIPART_TYPE_ALTERNATIVE = "alternative"; |
|
|
|
|
|
|
|
|
|
private static Log _log = LogFactoryUtil.getLog(MailEngine.class); |
|
|
|
|
private static final String _MULTIPART_TYPE_MIXED = "mixed"; |
|
|
|
|
|
|
|
|
|
private static final String _TEXT_HTML = "text/html;charset=\"UTF-8\""; |
|
|
|
|
|
|
|
|
|
private static final String _TEXT_PLAIN = "text/plain;charset=\"UTF-8\""; |
|
|
|
|
|
|
|
|
|
private static Log _log = LogFactoryUtil.getLog(MailEngine.class); |
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
Salvatore La Manna
4 anni fa