/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package lrp.queue.test;

import javax.ejb.MessageDriven;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
//import org.jboss.annotation.ejb.ResourceAdapter;
//import org.jboss.ejb3.annotation.ResourceAdapter;

@MessageDriven(name = "dum", activationConfig = {
    @javax.ejb.ActivationConfigProperty(propertyName = "maxSession", propertyValue = "10"),
    @javax.ejb.ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
    @javax.ejb.ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/dum")})
//@ResourceAdapter("hornetq-ra.rar")
//@ResourceAdapter("jms-ra.rar")
public class dumMDB implements MessageListener {

    public void onMessage(Message message) {
        try {
            if ((message instanceof TextMessage)) {
                TextMessage msg = (TextMessage) message;
                //System.out.println("MESSAGE BEAN !!!! ->: Message received @ MDB: " + msg.getText());

                System.out.println(msg.getText());
            } else {
                System.out.println("Non Text Message");
            }
            Thread.sleep(60000);

            if ((message instanceof TextMessage)) {
                TextMessage msg = (TextMessage) message;
                //System.out.println("MESSAGE BEAN !!!! ->: Message received @ MDB: " + msg.getText());

                System.out.println("Message Consume done : " + msg.getText());
            } else {
                System.out.println("Message Consume done");
            }

        } catch (JMSException e) {
            e.printStackTrace();
        } catch (Throwable te) {
            te.printStackTrace();
        }
    }
}