NewTodoMailerMessageBean.java

package com.todo.ejb;

import javax.ejb.ActivationConfigProperty;
import javax.ejb.EJB;
import javax.ejb.MessageDriven;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.ObjectMessage;
import javax.mail.MessagingException;

import com.todo.entity.Todo;

@MessageDriven(activationConfig =
{
  @ActivationConfigProperty(propertyName="destinationType",
    propertyValue="javax.jms.Queue"),
  @ActivationConfigProperty(propertyName="destination",
    propertyValue="queue/MyQueue")
})
public class NewTodoMailerMessageBean implements MessageListener {

	@EJB
	private MailSenderSessionBeanLocal mailSenderBean;

	public NewTodoMailerMessageBean(){
		
	}
	
	public void onMessage(Message message) {		
		try {
            ObjectMessage msg = null;
            
            if (message instanceof ObjectMessage) {
            	
                msg = (ObjectMessage) message;
                
                Todo todo=(Todo)msg.getObject();
                
                System.out.println("yeni todo eklendi :" + todo.getTitle());                
                
                String subject="yeni todo eklendi :"+todo.getTitle();
                String body="<br/>todo icerigi : "+todo.getText();
                
                mailSenderBean.sendMail("admin@godoro.com","membership@godoro.com",subject, body);
                
            }else{
            	System.out.println("message instanceof ObjectMessage false");
            }
        } catch (JMSException e) {
            e.printStackTrace();
        } catch (MessagingException e) {
			e.printStackTrace();
		} 
		
    }

}