package ejb;

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

@JMSDestinationDefinition(
    description = "global-scope resource defined by @JMSDestinationDefinition",
    name = "java:global/jms/myInboundQueue",
    className = "javax.jms.Queue",
    resourceAdapterName = "jmsra",
    destinationName = "myPhysicalQueue")

@MessageDriven(mappedName = "java:global/jms/myInboundQueue")

public class MessageBean implements MessageListener {

    @Override
    public void onMessage(Message inMessage) {
        TextMessage tm = (TextMessage) inMessage;
        try {
            System.out.println("message received: " + tm.getText());
        } catch (JMSException e) {
            throw new RuntimeException("Exception occured when retrieve message text", e);
        }
    }

}