TextMessageConsumerServlet.java

package com.book.jms;

import java.io.IOException;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSession;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

@WebServlet("/GetMessage")
public class TextMessageConsumerServlet extends HttpServlet {

	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		
		try {
			
			Context context = new InitialContext();
			
			QueueConnectionFactory factory = 
	                (QueueConnectionFactory)context.lookup("ConnectionFactory");
			
			QueueConnection connection = factory.createQueueConnection();
			 
			QueueSession session = connection.createQueueSession(false, 
	                    QueueSession.AUTO_ACKNOWLEDGE);
			
			Queue queue = (Queue)context.lookup("queue/MyQueue");
			
			MessageConsumer consumer = session.createConsumer(queue);
			
			connection.start();
			
			Message message = consumer.receive(1); 
			
		    if (message != null) { 
		        if (message instanceof TextMessage) { 
		        	
		        	TextMessage textMessage = (TextMessage) message; 
		        	
		            response.getWriter().println("mesaj: "+textMessage.getText());
		            
		        } 
		        
		    }
			
            session.close();
            connection.close();
            
		} catch (NamingException e) {
			e.printStackTrace();
		} catch (JMSException e) {
			e.printStackTrace();
		}
		
		
	}

	protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		doGet(request, response);
	}

}