package com.jdon.mailer.ejb;import javax.ejb.*;import javax.jms.*;import javax.naming.*;import org.apache.log4j.Logger;import com.jdon.mailer.Mail;import com.jdon.util.CastorHandler;import com.jdon.asyncsender.util.MailUtil;/** * * <p>Title: </p> * <p>Description: * 這是一個郵件發送的服務類。 * 屬于消息的消費者, 生產者通過queue/MailerMDB訪問本類。 * 采取XML文本作為參數傳送到本類onMessage * * </p> * <p>Copyright: Jdon.com Copyright (c) 2003</p> * <p>Company: 上海解道計算機技術有限公司</p> * @author banq * @version 1.0 */public class MailerBean implements MessageDrivenBean, MessageListener {  private final static Logger logger = Logger.getLogger(MailerBean.class);  MessageDrivenContext messageDrivenContext;  public void ejbCreate(){  }  public void ejbRemove() {    /**@todo Complete this method*/  }  public void onMessage(Message msg){    logger.debug(" --> enter onMessage ..");    TextMessage textMessage = null;    String xmlMailMessage = null;    Mail recMail = null;    try {      textMessage = (TextMessage) msg;      xmlMailMessage = textMessage.getText();      logger.debug(" --> O/R Map xmlMailMessage = " + xmlMailMessage);      recMail = MailUtil.getMailFromMsg(xmlMailMessage);      logger.debug(" --> begin connect the server ....");      sendMail(recMail);      logger.debug(" --> send mail ok ");    } catch (JMSException je) {      logger.error("MailerMDB.onMessag error" + je);      throw new EJBException("MailerMDB.onMessage" + je);    } catch (Exception me) {      logger.error("MailerMDB.onMessag error" + me);    }  }  private void sendMail(Mail mail) throws Exception{    getMailHelper().createAndSendMail(mail);  }  private MailHelper getMailHelper(){    return (new MailHelper());  }  public void setMessageDrivenContext(MessageDrivenContext messageDrivenContext) {    this.messageDrivenContext = messageDrivenContext;  }}