/*
* $Id: SmtpMessageDispatcher.java 19191 2010-08-25 21:05:23Z tcarlson $
* --------------------------------------------------------------------------------------
* Copyright (c) MuleSoft, Inc. All rights reserved. http://www.mulesoft.com
*
* The software in this package is published under the terms of the CPAL v1.0
* license, a copy of which has been included with this distribution in the
* LICENSE.txt file.
*/
package org.mule.transport.email;
import org.mule.DefaultMuleMessage;
import org.mule.api.MuleEvent;
import org.mule.api.MuleMessage;
import org.mule.api.endpoint.EndpointException;
import org.mule.api.endpoint.EndpointURI;
import org.mule.api.endpoint.OutboundEndpoint;
import org.mule.api.transport.DispatchException;
import org.mule.config.i18n.CoreMessages;
import org.mule.config.i18n.MessageFactory;
import org.mule.transport.AbstractMessageDispatcher;
import org.mule.transport.NullPayload;
import com.sun.mail.smtp.SMTPTransport;
import java.net.URLDecoder;
import java.util.Calendar;
import javax.mail.Message;
import javax.mail.MessagingException;
import javax.mail.Transport;
/**
* <code>SmtpMessageDispatcher</code> will dispatch Mule events as Mime email
* messages over an SMTP gateway.
*
* This contains a reference to a transport (and endpoint and connector, via superclasses)
*/
public class SmtpMessageDispatcher extends AbstractMessageDispatcher
{
private volatile Transport transport;
public SmtpMessageDispatcher(OutboundEndpoint endpoint)
{
super(endpoint);
}
private SmtpConnector castConnector()
{
return (SmtpConnector) getConnector();
}
@Override
protected void doConnect() throws Exception
{
if (transport == null)
{
try
{
transport = castConnector().getSessionDetails(endpoint).newTransport();
EndpointURI uri = endpoint.getEndpointURI();
String encoding = endpoint.getEncoding();
String user = (uri.getUser()!=null ? URLDecoder.decode(uri.getUser(), encoding) : null);
String pass = (uri.getPassword()!=null ? URLDecoder.decode(uri.getPassword(), encoding) : null);
transport.connect(uri.getHost(), uri.getPort(), user, pass);
}
catch (Exception e)
{
throw new EndpointException(
MessageFactory.createStaticMessage("Unable to connect to mail transport."), e);
}
}
}
@Override
protected void doDisconnect() throws Exception
{
if (null != transport)
{
try
{
transport.close();
}
finally
{
transport = null;
}
}
}
@Override
protected void doDispatch(MuleEvent event) throws Exception
{
Object data = event.getMessage().getPayload();
if (!(data instanceof Message))
{
throw new DispatchException(
CoreMessages.transformUnexpectedType(data.getClass(), Message.class),
event, this);
}
else
{
// Check the message for any unset data and use defaults
sendMailMessage((Message) data);
}
}
@Override
protected MuleMessage doSend(MuleEvent event) throws Exception
{
doDispatch(event);
return new DefaultMuleMessage(NullPayload.getInstance(), connector.getMuleContext());
}
protected void sendMailMessage(Message message) throws MessagingException
{
// sent date
message.setSentDate(Calendar.getInstance().getTime());
// Double check that the transport is still connected as some SMTP servers may
// disconnect idle connections.
if (isTransportConnected() == false)
{
EndpointURI uri = endpoint.getEndpointURI();
if (logger.isInfoEnabled())
{
logger.info("Connection closed by remote server. Reconnecting.");
}
transport.connect(uri.getHost(), uri.getPort(), uri.getUser(), uri.getPassword());
}
transport.sendMessage(message, message.getAllRecipients());
if (logger.isDebugEnabled())
{
StringBuffer msg = new StringBuffer();
msg.append("Email message sent with subject'").append(message.getSubject()).append("' sent- ");
msg.append(", From: ").append(MailUtils.mailAddressesToString(message.getFrom())).append(" ");
msg.append(", To: ").append(
MailUtils.mailAddressesToString(message.getRecipients(Message.RecipientType.TO))).append(" ");
msg.append(", Cc: ").append(
MailUtils.mailAddressesToString(message.getRecipients(Message.RecipientType.CC))).append(" ");
msg.append(", Bcc: ")
.append(MailUtils.mailAddressesToString(message.getRecipients(Message.RecipientType.BCC)))
.append(" ");
msg.append(", ReplyTo: ").append(MailUtils.mailAddressesToString(message.getReplyTo()));
logger.debug(msg.toString());
}
}
// Fix incompatibility between JavaMail and Exchange
// see http://forums.sun.com/thread.jspa?threadID=5409031&tstart=1
protected boolean isTransportConnected()
{
boolean isConnected = false;
isConnected = transport.isConnected();
if (isConnected)
{
SMTPTransport smtpTransport = (SMTPTransport) transport;
String lastServerResponse = smtpTransport.getLastServerResponse();
if (lastServerResponse.startsWith("250") == false)
{
isConnected = false;
try
{
smtpTransport.close();
}
catch (MessagingException me)
{
if (logger.isInfoEnabled())
{
logger.info("Unable to close SMTP Transport", me);
}
}
}
}
return isConnected;
}
@Override
protected void doDispose()
{
// nothing doing
}
}