package dk.thoerup.messagedriven;

import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;


//destination must be created on server before deployment
//GFv3 -> resourcces -> JMS resources -> destination resources -> new
@MessageDriven(mappedName = "jms/hello", activationConfig =  {
        @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"),
        @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue")
    })


public class MDBean implements MessageListener {

	@Override
	public void onMessage(Message message) {
		
		try {
			System.out.println("onMessage: " + message.getStringProperty("name") );
			
			if (message instanceof TextMessage) {
				TextMessage txt = (TextMessage) message;
				System.out.println("Body" + txt.getText() );
			}
			
		} catch (JMSException e) {
			System.out.println( e.getMessage() );
		}
				
	} 
}