mailerbean.java

展示使用J2EE容器实现安全机制

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;
  }
}