TextMessageListener.java

package com.book.jms;

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


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

	@Override
	public void onMessage(Message message) {
		
		if(message instanceof TextMessage){
			
			 try {
				TextMessage textMessage = (TextMessage) message;
				 
				 System.out.println("mesaj alındı : "+textMessage.getText());
				 
			} catch (JMSException e) {
				e.printStackTrace();
			}
			
		}
		
	}

}