UtilBean.java

package fi.insomnia.bortal.beans;

import java.util.Date;

import javax.annotation.Resource;
import javax.ejb.Local;
import javax.ejb.Stateless;
import javax.jms.JMSException;
import javax.jms.ObjectMessage;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.Session;
import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;
import javax.persistence.PersistenceContext;
import javax.persistence.PersistenceUnit;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import fi.insomnia.bortal.util.MailMessage;

/**
 * Session Bean implementation class UtilBean
 */
@Stateless
@Local
public class UtilBean implements UtilBeanLocal {

    private static final Logger logger = LoggerFactory.getLogger(UtilBean.class);

    @PersistenceContext
    private EntityManager em;

    @PersistenceUnit
    private EntityManagerFactory emf;
   
    
    /**
     * Default constructor.
     */
    public UtilBean() {
        // TODO Auto-generated constructor stub
    }

    @Resource(name = "jmsQueue", mappedName = "jms/mailque")
    private Queue mailQueue;
    @Resource(name = "connFactory", mappedName = "jms/mailconnectionfactory")
    private QueueConnectionFactory mailQuefactory;

    @Override
    public boolean sendMail(MailMessage message) {
        Date d = new Date();
        try {
            QueueConnection conn = mailQuefactory.createQueueConnection();
            Session session = conn.createSession(false, 1);
            ObjectMessage objmessage = session.createObjectMessage(message);

            session.createProducer(mailQueue).send(objmessage);
            conn.close();
        } catch (JMSException e) {
            logger.debug("Got exception sending mail", e);
        }
        logger.debug("Message time {}",new Date().getTime() - d.getTime());
        return true;
    }

}