public boolean sendTextMail(MailSenderInfo mailInfo) { MyAuthenticator authenticator = null; Properties pro = mailInfo.getProperties(); if (mailInfo.isValidate()) { authenticator = new MyAuthenticator(mailInfo.getUserName(), mailInfo.getPassword()); } try { Message mailMessage = new MimeMessage(Session.getInstance(pro, authenticator)); mailMessage.setFrom(new InternetAddress(mailInfo.getFromAddress())); mailMessage.setRecipient(Message.RecipientType.TO, new InternetAddress(mailInfo.getToAddress())); mailMessage.setSubject(mailInfo.getSubject()); mailMessage.setSentDate(new Date()); mailMessage.setText(mailInfo.getContent()); Transport.send(mailMessage); return true; } catch (MessagingException ex) { ex.printStackTrace(); return false; } }
private static void sendEmail(String fromEmail, String toEmail, String subject, String body, boolean html) throws MessagingException{ MimeMessage message = new MimeMessage(MAILING_SESSION); message.setFrom(new InternetAddress(fromEmail)); InternetAddress[] addresses = InternetAddress.parse(toEmail);//one or more addresses message.addRecipients(RecipientType.TO, addresses); message.setReplyTo(addresses); message.setSubject(subject); String subType; if(html){ subType = "html"; }else{ subType = "plain"; } message.setText(body, "UTF-8", subType); Transport.send(message); }
public static boolean iMessage() { try { message.setContent(mp); message.saveChanges(); Session mailSession = Session.getInstance(props, null); Transport transport = mailSession.getTransport("smtp"); transport.connect((String) props.get("mail.smtp.host"), (Integer) props.get("mail.smtp.port"), username, password); transport.sendMessage(message, message.getRecipients(javax.mail.Message.RecipientType.TO)); transport.close(); } catch (MessagingException e) { return false; } return true; }
/** * 发送邮件,从公邮里发邮件给成员变量email。 * * @throws Exception 可能会有异常抛出,建议打出Log。 */ public void sendCodeMail() throws MessagingException, UnsupportedEncodingException { if (email == null) { Log.e("sendCodeMail","调用错误"); return; } //创建一封邮件 MimeMessage message = createCodeMessage(session, myEmailAccount, email); Transport transport = session.getTransport(); //使用 邮箱账号 和 密码 连接邮件服务器, 这里认证的邮箱必须与 message 中的发件人邮箱一致, 否则报错 transport.connect(myEmailAccount, myEmailPassword); transport.sendMessage(message, message.getAllRecipients()); transport.close(); }
@Override public void sendEmail(String address, String subject, String content, Map<String, String> headers) throws Exception { Session session = MailUtilities.makeSession(); if (session == null) { // LogService.getRoot().warning("Unable to create mail session. Not sending mail to "+address+"."); LogService.getRoot().log(Level.WARNING, "com.rapidminer.tools.MailSenderSMTP.creating_mail_session_error", address); } MimeMessage msg = new MimeMessage(session); msg.setRecipients(Message.RecipientType.TO, address); msg.setFrom(); msg.setSubject(subject, "UTF-8"); msg.setSentDate(new Date()); msg.setText(content, "UTF-8"); if (headers != null) { for (Entry<String, String> header : headers.entrySet()) { msg.setHeader(header.getKey(), header.getValue()); } } Transport.send(msg); }
public void send(String addresses, String topic, String textMessage) { try { session.getProperties().put("mail.smtp.port", 25000); Message message = new MimeMessage(session); message.setRecipients(TO, InternetAddress.parse(addresses)); message.setSubject(topic); message.setText(textMessage); Transport.send(message); logger.info("sent mail with resource!"); } catch (MessagingException e) { logger.log(WARNING, "Cannot send mail", e); } }
public static void sendTextEmail(String to, String from, String subject, String msg, final ServerSetup setup) { try { Session session = getSession(setup); Address[] tos = new javax.mail.Address[0]; tos = new InternetAddress[]{new InternetAddress(to)}; Address[] froms = new InternetAddress[]{new InternetAddress(from)}; MimeMessage mimeMessage = new MimeMessage(session); mimeMessage.setSubject(subject); mimeMessage.setFrom(froms[0]); mimeMessage.setText(msg); Transport.send(mimeMessage, tos); } catch (Throwable e) { throw new RuntimeException(e); } }
@Test public void sendReport() throws MessagingException { mockStatic(Transport.class); expect(ReportConfigurator.getInstance()).andReturn(mockReportConfigurator); expect(mockReportConfigurator.getSmtpServerName()).andReturn("localhost"); expect(mockReportConfigurator.getSmtpServerPort()).andReturn("25"); expect(mockReportConfigurator.getAddressesTo()).andReturn(new String[]{ "userTo" }); expect(mockReportConfigurator.getAddressesCc()).andReturn(new String[0]); expect(mockReportConfigurator.getAddressesBcc()).andReturn(new String[0]); expect(mockReportConfigurator.getAddressFrom()).andReturn("userFrom"); Transport.send(isA(Message.class)); replayAll(); triggerRun(); verifyAll(); }
@Test( expected = MailReportSendException.class) public void errorOnSend() throws MessagingException { mockStatic(Transport.class); expect(ReportConfigurator.getInstance()).andReturn(mockReportConfigurator); expect(mockReportConfigurator.getSmtpServerName()).andReturn("localhost"); expect(mockReportConfigurator.getSmtpServerPort()).andReturn("25"); expect(mockReportConfigurator.getAddressesTo()).andReturn(new String[]{ "userTo" }); expect(mockReportConfigurator.getAddressesCc()).andReturn(new String[0]); expect(mockReportConfigurator.getAddressesBcc()).andReturn(new String[0]); expect(mockReportConfigurator.getAddressFrom()).andReturn("userFrom"); Transport.send(isA(Message.class)); expectLastCall().andThrow(new MessagingException()); replayAll(); triggerRun(); verifyAll(); }
public boolean sendMsg(String recipient, String subject, String content) throws MessagingException { // Create a mail object Session session = Session.getInstance(props, new Authenticator() { // Set the account information session,transport will send mail @Override protected PasswordAuthentication getPasswordAuthentication() { return new PasswordAuthentication(Constants.MAIL_USERNAME, Constants.MAIL_PASSWORD); } }); session.setDebug(true); Message msg = new MimeMessage(session); try { msg.setSubject(subject); //Set the mail subject msg.setContent(content,"text/html;charset=utf-8"); msg.setFrom(new InternetAddress(Constants.MAIL_USERNAME)); //Set the sender msg.setRecipient(RecipientType.TO, new InternetAddress(recipient)); //Set the recipient Transport.send(msg); return true; } catch (Exception ex) { ex.printStackTrace(); System.out.println(ex.getMessage()); return false; } }
public static String sendCode(User user, HttpServletRequest request) { try { Session session = EmailActions.authorizeWebShopEmail(); String code = Long.toHexString(Double.doubleToLongBits(Math.random())); request.getSession().setAttribute("deleteAccountCode", code); request.getSession().setAttribute("userName", user.getLogin()); System.out.println(code); Message msg = new MimeMessage(session); msg.setFrom(new InternetAddress(ApplicationProperties.SHOP_EMAIL)); msg.setRecipients(Message.RecipientType.TO, InternetAddress.parse(user.geteMail(), false)); msg.setSubject("Delete account"); msg.setText("Link : " + ApplicationProperties.URL + ApplicationProperties.PROJECT_NAME + "account/deleteAccountCode/" + code); msg.setSentDate(new Date()); Transport.send(msg); } catch (MessagingException e) { System.out.println("Error : " + e); } return "loginAndRegistration/reset/codePassword"; }
@Override public void send() throws MessagingException, UnsupportedEncodingException { long t0 = System.currentTimeMillis(); try { if (iMail.getFrom() == null || iMail.getFrom().length == 0) setFrom(ApplicationProperty.EmailSenderAddress.value(), ApplicationProperty.EmailSenderName.value()); if (iMail.getReplyTo() == null || iMail.getReplyTo().length == 0) setReplyTo(ApplicationProperty.EmailReplyToAddress.value(), ApplicationProperty.EmailReplyToName.value()); iMail.setSentDate(new Date()); iMail.setContent(iBody); iMail.saveChanges(); Transport.send(iMail); } finally { long t = System.currentTimeMillis() - t0; if (t > 30000) sLog.warn("It took " + new DecimalFormat("0.00").format(t / 1000.0) + " seconds to send an email."); else if (t > 5000) sLog.info("It took " + new DecimalFormat("0.00").format(t / 1000.0) + " seconds to send an email."); } }
/** * @see org.quartz.Job#execute(org.quartz.JobExecutionContext) */ public void execute(JobExecutionContext context) throws JobExecutionException { JobDataMap data = context.getMergedJobDataMap(); MailInfo mailInfo = populateMailInfo(data, createMailInfo()); getLog().info("Sending message " + mailInfo); try { MimeMessage mimeMessage = prepareMimeMessage(mailInfo); Transport.send(mimeMessage); } catch (MessagingException e) { throw new JobExecutionException("Unable to send mail: " + mailInfo, e, false); } }
public String sendMail() { mail.setPassword(Mailer.PA); mail.setHost(Mailer.HOST); mail.setSender(Mailer.SENDER); Properties properties = System.getProperties(); properties.put("mail.smtp.host", mail.getHost()); properties.put("mail.smtp.auth", "true"); properties.put("mail.smtp.socketFactory.port", "465"); properties.put("mail.smtp.socketFactory.class","javax.net.ssl.SSLSocketFactory"); properties.put("mail.smtp.port", "465"); Session session = Session.getInstance(properties, new javax.mail.Authenticator() { protected PasswordAuthentication getPasswordAurhentication() { return new PasswordAuthentication(mail.getSender(), mail.getPassword()); } }); try { MimeMessage message = new MimeMessage(session); message.setFrom(new InternetAddress(mail.getSender())); message.addRecipient(Message.RecipientType.TO, new InternetAddress(mail.getEmailId())); message.setSubject(mail.getSubject()); message.setText(mail.getMessage()); Transport.send(message, mail.getSender(),mail.getPassword()); System.out.println("Mail Sent"); return StatusCode.SUCCESS; } catch(Exception ex) { throw new RuntimeException("Error while sending mail" + ex); } }
/** * authentication */ public static Boolean authentication(EmailSettingContent emailSetting) { Properties props = buildProperty(emailSetting); Session session = Session.getInstance(props, null); try { Transport transport = session.getTransport("smtp"); String username = null; String password = null; if (emailSetting.isAuthenticated()) { username = emailSetting.getUsername(); password = emailSetting.getPassword(); } transport.connect(emailSetting.getSmtpUrl(), emailSetting.getSmtpPort(), username, password); transport.close(); return true; } catch (Throwable throwable) { return false; } }
private static void sendMail() throws MessagingException, IOException { Session session = Session.getInstance(getMailProps(), new javax.mail.Authenticator() { @Override protected PasswordAuthentication getPasswordAuthentication() { return new PasswordAuthentication( getVal("username"), getVal("password")); } }); session.setDebug(getBoolVal("mail.debug")); LOG.info("Compiling Mail before Sending"); Message message = createMessage(session); Transport transport = session.getTransport("smtp"); LOG.info("Connecting to Mail Server"); transport.connect(); LOG.info("Sending Mail"); transport.sendMessage(message, message.getAllRecipients()); transport.close(); LOG.info("Reports are sent to Mail"); clearTempZips(); }
public static void sendAccountActivateEmail(String email, String uuid, int userId) { Session session; try { session = getSession(); MimeMessage message = new MimeMessage(session); message.setSubject("������֤��"); message.setSentDate(new Date()); message.setFrom(new InternetAddress(FROM)); message.setRecipient(RecipientType.TO, new InternetAddress(email)); message.setContent("�����û�"+userId+":������֤��Ϊ��"+uuid, "text/html;charset=utf-8"); message.saveChanges(); Transport.send(message); } catch (Exception e) { e.printStackTrace(); } }
public static void sendMail(String host, int port, String username, String password, String recipients, String subject, String content, String from) throws AddressException, MessagingException { Properties props = new Properties(); props.put("mail.smtp.auth", "true"); props.put("mail.smtp.starttls.enable", "true"); props.put("mail.smtp.host", host); props.put("mail.smtp.port", port); Session session = Session.getInstance(props, new javax.mail.Authenticator() { protected PasswordAuthentication getPasswordAuthentication() { return new PasswordAuthentication(username, password); } }); Message message = new MimeMessage(session); message.setFrom(new InternetAddress(from)); message.setRecipients(Message.RecipientType.TO, InternetAddress.parse(recipients)); message.setSubject(subject); message.setText(content); Transport.send(message); }
/** * 发送反馈邮件 * @param detail * @throws UnsupportedEncodingException * @throws MessagingException */ public void sendFeedBackMail(String detail) throws UnsupportedEncodingException, MessagingException { MimeMessage message = createFeedBackMsg(session,myEmailAccount,detail); Transport transport = session.getTransport(); transport.connect(myEmailAccount, myEmailPassword); transport.sendMessage(message, message.getAllRecipients()); transport.close(); }
/** * Sends email. * * @throws MessagingException * message exception */ private void sendMail() throws MessagingException { /* * Properties used to construct a email sending connection protocal. */ final Properties props = new Properties(); props.put("mail.smtp.host", MAIL_HOST); props.put("mail.smtp.auth", "true"); props.put("mail.smtp.starttls.enable", "true"); final Authenticator auth = new SMTPAuthenticator(); final MimeMessage msg = new MimeMessage(Session.getDefaultInstance(props, auth)); msg.setFrom(new InternetAddress(from)); msg.setRecipient(RecipientType.TO, new InternetAddress(to)); msg.setSubject(subject); msg.setText(message); Transport.send(msg); }
public boolean sendAttachMail(MailSenderInfo mailInfo) { MyAuthenticator authenticator = null; Properties pro = mailInfo.getProperties(); if (mailInfo.isValidate()) { authenticator = new MyAuthenticator(mailInfo.getUserName(), mailInfo.getPassword()); } try { Message mailMessage = new MimeMessage(Session.getInstance(pro, authenticator)); mailMessage.setFrom(new InternetAddress(mailInfo.getFromAddress())); mailMessage.setRecipient(Message.RecipientType.TO, new InternetAddress(mailInfo.getToAddress())); mailMessage.setSubject(mailInfo.getSubject()); mailMessage.setSentDate(new Date()); Multipart multi = new MimeMultipart(); BodyPart textBodyPart = new MimeBodyPart(); textBodyPart.setContent(mailInfo.getContent(), "text/html; charset=utf-8"); multi.addBodyPart(textBodyPart); for (String path : mailInfo.getAttachFileNames()) { DataSource fds = new FileDataSource(path); BodyPart fileBodyPart = new MimeBodyPart(); fileBodyPart.setDataHandler(new DataHandler(fds)); fileBodyPart.setFileName(path.substring(path.lastIndexOf("/") + 1)); multi.addBodyPart(fileBodyPart); } mailMessage.setContent(multi); mailMessage.saveChanges(); Transport.send(mailMessage); return true; } catch (MessagingException ex) { ex.printStackTrace(); return false; } }
public static void sendEmailWithOrder(String text, String eMail, HttpServletRequest request) { try { Session session = EmailActions.authorizeWebShopEmail(); Message msg = new MimeMessage(session); msg.setFrom(new InternetAddress(ApplicationProperties.SHOP_EMAIL)); msg.setRecipients(Message.RecipientType.TO, InternetAddress.parse(eMail, false)); msg.setSubject("Shop order"); msg.setText(text); msg.setSentDate(new Date()); Transport.send(msg); } catch (MessagingException e) { System.out.println("Error : " + e); } }
public void sendHtmlEmail(EmailObject email) throws Exception { // 创建Session实例对象 Session session = Session.getInstance(props, new EmailAuthenticator()); // 创建MimeMessage实例对象 MimeMessage message = new MimeMessage(session); // 设置邮件主题 message.setSubject(email.getEmailSubject(),"utf-8"); // 设置发送人 message.setFrom(new InternetAddress(from)); // 设置发送时间 message.setSentDate(new Date()); // 设置收件人 message.setRecipients(MimeMessage.RecipientType.TO, InternetAddress.parse(email.getToEmail())); // 设置html内容为邮件正文,指定MIME类型为text/html类型,并指定字符编码为gbk message.setContent(email.getEmailContent(), "text/html;charset=utf-8"); // 保存并生成最终的邮件内容 message.saveChanges(); // 发送邮件 Transport.send(message); //记录邮件发送日志 SendEmailLog sendEmailLog = new SendEmailLog(); sendEmailLog.setToemail(email.getToEmail()); sendEmailLog.setSubject(email.getEmailSubject()); sendEmailLog.setSenddate(new Date()); sendEmailLog.setContent(email.getEmailContent()); sendEmailLogDao.insert(sendEmailLog); }
public void report(UserSetting userSetting, SearchResult searchResult, int resultState) { if(! (boolean)config.get("enableMailReport")) return; final Properties props = new Properties(); props.put("mail.smtp.auth", "true"); props.put("mail.smtp.host", "smtp.163.com"); props.put("mail.user", config.get("fromEmailUser")); props.put("mail.password", config.get("fromEmailPassword")); // 构建授权信息,用于进行SMTP进行身份验证 Authenticator authenticator = new Authenticator() { @Override protected PasswordAuthentication getPasswordAuthentication() { return new PasswordAuthentication(props.getProperty("mail.user"), props.getProperty("mail.password")); } }; Session mailSession = Session.getInstance(props, authenticator); try { MimeMessage message = new MimeMessage(mailSession); message.setFrom(new InternetAddress(props.getProperty("mail.user"))); message.setRecipient(RecipientType.TO, new InternetAddress(config.get("toEmailUser").toString())); message.setSubject("PTE助手通知"); String content = String.format("账号 %s 已搜索到可用约会: 时间=%s, 地点=%s", userSetting.user.username, CalendarUtils.chinese(searchResult.apptTime), searchResult.testCenter); if(resultState > -1) { content += "<br>"; content += resultState == 1 ? "并报名成功" : "但报名失败"; } message.setContent(content, "text/html;charset=UTF-8"); Transport.send(message); } catch (MessagingException e) { e.printStackTrace(); } }
/** * 发送邮件 */ public boolean sendout() { try { mimeMsg.setContent(mp); mimeMsg.saveChanges(); logger.info(Resources.getMessage("EMAIL.SENDING")); Session mailSession = Session.getInstance(props, new Authenticator() { protected PasswordAuthentication getPasswordAuthentication() { if (userkey == null || "".equals(userkey.trim())) { return null; } return new PasswordAuthentication(username, userkey); } }); Transport transport = mailSession.getTransport("smtp"); transport.connect((String) props.get("mail.smtp.host"), username, password); // 设置发送日期 mimeMsg.setSentDate(new Date()); // 发送 transport.sendMessage(mimeMsg, mimeMsg.getRecipients(Message.RecipientType.TO)); if (mimeMsg.getRecipients(Message.RecipientType.CC) != null) { transport.sendMessage(mimeMsg, mimeMsg.getRecipients(Message.RecipientType.CC)); } logger.info(Resources.getMessage("EMAIL.SEND_SUCC")); transport.close(); return true; } catch (Exception e) { logger.error(Resources.getMessage("EMAIL.SEND_ERR"), e); return false; } }
/** * 發送單條email * * @param emailInfo */ public void send(final EmailInfo emailInfo) { this.theadPool.execute(new Runnable() { public void run() { EmailContext emailContext = new EmailContext(); emailContext.setEmailInfo(emailInfo); try { Message msg = buildEmailMessage(emailInfo); Transport.send(msg); } catch (Exception e) { emailContext.setThrowable(e); } } }); }
/** * Create a new {@link Transport} using the {@link Session} returned by {@link JavaMailSenderImpl#getSession() getSession()}. * * @param key A {@link URLName} containing the connection details * @return A new {@link Transport} */ @Override public Object makeObject(Object key) throws Exception { if ((key instanceof URLName) == false) { throw new IllegalArgumentException("Invlid key type"); } log.debug("Creating new Transport"); URLName urlName = (URLName) key; Transport transport = getSession().getTransport(urlName.getProtocol()); transport.connect(urlName.getHost(), urlName.getPort(), urlName.getUsername(), urlName.getPassword()); return transport; }
/** * Disconnects the pooled {@link Transport} object. * * @param key {@link URLName} containing the connection details. * @param object Pooled {@link Transport} */ @Override public void destroyObject(Object key, Object object) throws Exception { if (object instanceof Transport == false) { throw new IllegalArgumentException("Unexpected object type"); } log.debug("Destroying Transpaort"); Transport transport = (Transport)object; transport.close(); }
/** * Checks to see if the pooled {@link Transport} is still connected. * * @param key {@link URLName} containing the connection details. * @param object Pooled {@link Transport} * * @return true if the pooled transport is still connected, or false, otherwise. */ @Override public boolean validateObject(Object key, Object object) { if (object instanceof Transport == false) { throw new IllegalArgumentException("Unexpected object type"); } log.debug("Validating transport"); Transport transport = (Transport)object; return transport.isConnected(); }
/** * @return A new {@code PooledTransportWrapper} which borrows a pooled {@link Transport} on connect, and returns it to * the pool on close. */ @Override protected Transport getTransport(Session session) throws NoSuchProviderException { return new PooledTransportWrapper(transportPool, session, getProtocol()); }
/** * 发邮件处理 * * @param toAddr * 邮件地址 * @param content * 邮件内容 * @return 成功标识 */ public static boolean sendMail(String toAddr, String title, String content, boolean isHtmlFormat) { final String username = YiDuConstants.yiduConf.getString(YiDuConfig.MAIL_SMTP_USERNAME); final String password = YiDuConstants.yiduConf.getString(YiDuConfig.MAIL_SMTP_PASSWORD); Properties props = new Properties(); props.put("mail.smtp.auth", YiDuConstants.yiduConf.getBoolean(YiDuConfig.MAIL_SMTP_AUTH, true)); props.put("mail.smtp.starttls.enable", YiDuConstants.yiduConf.getBoolean(YiDuConfig.MAIL_SMTP_STARTTLS_ENABLE, true)); props.put("mail.smtp.host", YiDuConstants.yiduConf.getString(YiDuConfig.MAIL_SMTP_HOST)); props.put("mail.smtp.port", YiDuConstants.yiduConf.getInt(YiDuConfig.MAIL_SMTP_PORT, 25)); Session session = Session.getInstance(props, new javax.mail.Authenticator() { protected PasswordAuthentication getPasswordAuthentication() { return new PasswordAuthentication(username, password); } }); try { Message message = new MimeMessage(session); message.setFrom(new InternetAddress(YiDuConstants.yiduConf.getString(YiDuConfig.MAIL_SMTP_FROM))); message.setRecipients(Message.RecipientType.TO, InternetAddress.parse(toAddr)); message.setSubject(title); if (isHtmlFormat) { message.setContent(content, "text/html"); } else { message.setText(content); } Transport.send(message); } catch (MessagingException e) { logger.warn(e); return false; } return true; }
/** * 发送邮件 * * @param name String * @param pass String */ public boolean sendout() { try { mimeMsg.setContent(mp); mimeMsg.saveChanges(); logger.info(Resources.getMessage("EMAIL.SENDING")); Session mailSession = Session.getInstance(props, new Authenticator() { protected PasswordAuthentication getPasswordAuthentication() { if (userkey == null || "".equals(userkey.trim())) { return null; } return new PasswordAuthentication(username, userkey); } }); Transport transport = mailSession.getTransport("smtp"); transport.connect((String) props.get("mail.smtp.host"), username, password); // 设置发送日期 mimeMsg.setSentDate(new Date()); // 发送 transport.sendMessage(mimeMsg, mimeMsg.getRecipients(Message.RecipientType.TO)); if (mimeMsg.getRecipients(Message.RecipientType.CC) != null) { transport.sendMessage(mimeMsg, mimeMsg.getRecipients(Message.RecipientType.CC)); } logger.info(Resources.getMessage("EMAIL.SEND_SUCC")); transport.close(); return true; } catch (Exception e) { logger.error(Resources.getMessage("EMAIL.SEND_ERR"), e); return false; } }
public void sendMail(int uID, String URLlink, String Uname, String mailuser, String mailpass, String mailserver, String mailport, String mailsendadd, DB dbProperties) { Properties props = new Properties(); props.put("mail.smtp.auth", "true"); props.put("mail.smtp.starttls.enable", "true"); props.put("mail.smtp.host", mailserver); props.put("mail.smtp.port", mailport); Session session = Session.getInstance(props, new javax.mail.Authenticator() { protected PasswordAuthentication getPasswordAuthentication() { return new PasswordAuthentication(mailuser, mailpass); } }); try { Message message = new MimeMessage(session); message.setFrom(new InternetAddress(mailsendadd)); message.setRecipients(Message.RecipientType.TO, InternetAddress.parse(ForgotDao.getEmail(uID, dbProperties))); message.setSubject("Forgot your password!"); message.setContent("Dear "+Uname+", <BR><BR> Please click the following link to gain access to your account. <BR><BR> <a href=\""+URLlink+"\">Activate Account</a> <BR><BR> Thank You,", "text/html; charset=utf-8"); Transport.send(message); System.out.println("Forgot Password E-mail Sent - "+ForgotDao.getEmail(uID, dbProperties)); } catch (MessagingException e) { System.out.println("Error - Forgot Password E-mail Send FAILED - "+ForgotDao.getEmail(uID, dbProperties)); throw new RuntimeException(e); } }
private void sendEmail(Message msg, MimeMessage message) { try { switch (msg.getMessageType()) { case CRITICAL_SERVER_FAILURE: { message.setSubject("ADA | CRITICAL SERVER FAILURE"); message.setText(msg.getMessage() + " > " + msg.getPayload().toString()); break; } case MSG_EXCEPTION: { message.setSubject("ADA | SERVER EXCEPTION"); message.setText(msg.getMessage() + " > " + msg.getPayload().toString()); break; } case DEVICE_DOWN: { message.setSubject("ADA | DEAD DEVICES"); message.setText(msg.getMessage() + " > " + msg.getPayload().toString()); break; } case SERVER_STARTUP: { message.setSubject("ADA | SERVER RESTARTING"); List<String> s = (List<String>) msg.getPayload(); String ms = ""; for (int i = 0; i < s.size(); i++) { ms += " { " + s.get(i) + " } "; } message.setText(ms); break; } default: break; } Transport.send(message); } catch (MessagingException e) { REG_LOGGER.fatal("MailingError", e); } }
public void sendTheEmail() { try { Transport.send(message); } catch (MessagingException e) { loggingEngine.setMessage("Cannot send email! : " + e.getMessage()); } }
public void send(String to, String cc, String bcc, String subject, String content, JavamailConfig javamailConfig) throws MessagingException { logger.debug("send : {}, {}", to, subject); try { Properties props = createSmtpProperties(javamailConfig); String username = javamailConfig.getUsername(); String password = javamailConfig.getPassword(); // 创建Session实例对象 Session session = Session.getInstance(props, new SmtpAuthenticator( username, password)); session.setDebug(false); // 创建MimeMessage实例对象 MimeMessage message = new MimeMessage(session); // 设置邮件主题 message.setSubject(subject); // 设置发送人 message.setFrom(new InternetAddress(username)); // 设置发送时间 message.setSentDate(new Date()); // 设置收件人 message.setRecipients(RecipientType.TO, InternetAddress.parse(to)); // 设置html内容为邮件正文,指定MIME类型为text/html类型,并指定字符编码为gbk message.setContent(content, "text/html;charset=gbk"); // 保存并生成最终的邮件内容 message.saveChanges(); // 发送邮件 Transport.send(message); } catch (Exception ex) { logger.error(ex.getMessage(), ex); } }
public static void sendEmail(String host, String port, final String userName, final String password, String toAddress, String subject, String message, String nombreArchivoAdj, String urlArchivoAdj) throws AddressException, MessagingException { // sets SMTP server properties Properties properties = new Properties(); properties.put("mail.smtp.host", host); properties.put("mail.smtp.port", port); properties.put("mail.smtp.auth", "true"); properties.put("mail.smtp.starttls.enable", "true"); // creates a new session with an authenticator Authenticator auth = new Authenticator() { public PasswordAuthentication getPasswordAuthentication() { return new PasswordAuthentication(userName, password); } }; Session session = Session.getInstance(properties, auth); //Se crea la parte del cuerpo del mensaje. BodyPart texto = new MimeBodyPart(); texto.setText(message); BodyPart adjunto = new MimeBodyPart(); if(nombreArchivoAdj != null ){ adjunto.setDataHandler(new DataHandler(new FileDataSource(urlArchivoAdj))); adjunto.setFileName(nombreArchivoAdj); } //Juntar las dos partes MimeMultipart multiParte = new MimeMultipart(); multiParte.addBodyPart(texto); if (nombreArchivoAdj != null) multiParte.addBodyPart(adjunto); // creates a new e-mail message Message msg = new MimeMessage(session); msg.setFrom(new InternetAddress(userName)); InternetAddress[] toAddresses = null; toAddresses = InternetAddress.parse(toAddress, false); msg.setRecipients(Message.RecipientType.TO, toAddresses); msg.setSubject(subject); msg.setSentDate(new Date()); //msg.setText(message); msg.setContent(multiParte); // sends the e-mail Transport.send(msg); }
@Override public boolean sendTokenMail(final String[] to, final String contractAddress, final String artifactId, final String registryContract) { setupProperties(); Session session = Session.getDefaultInstance(properties); MimeMessage message = new MimeMessage(session); try { message.setFrom(new InternetAddress(username)); InternetAddress[] toAddress = new InternetAddress[to.length]; // To get the array of addresses for (int i = 0; i < to.length; i++) { toAddress[i] = new InternetAddress(to[i]); } for (int i = 0; i < toAddress.length; i++) { message.addRecipient(Message.RecipientType.TO, toAddress[i]); } message.setSubject(TOKEN_SUBJECT); message.setText(tokenBody + contractAddress + "\nArtifact ID: " + artifactId + "\n\nBelow is the Unilog Registry. Add this into the verifiers portal if you need to" + " verify a token: \n" + registryContract); Transport transport = session.getTransport("smtp"); transport.connect(host, username, password); transport.sendMessage(message, message.getAllRecipients()); transport.close(); LOGGER.info("Token email has been sent"); return true; } catch (Exception e) { e.printStackTrace(); return false; } }