thoerup/messagedriven/ReverserServlet.java

package dk.thoerup.messagedriven;

import java.io.IOException;

import javax.annotation.Resource;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueReceiver;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TextMessage;
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(name = "ReverserServlet", urlPatterns = { "/ReverserServlet" })
public class ReverserServlet extends HttpServlet {
        private static final long serialVersionUID = 1L;
    
    // resource mapped vars may of course not be static !
    @Resource(mappedName = "jms/helloFactory")
    private QueueConnectionFactory connectionFactory;

    @Resource(mappedName = "jms/reverse")
    private Queue queue;
    
    @Resource(mappedName = "jms/reverseResponse")
    private Queue responseQueue;
    

        protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
                String msg = request.getParameter("msg");
                if (msg == null) 
                        msg = "Default";
                
                try {

                        
                        QueueConnection connection = connectionFactory.createQueueConnection();                 
                        
                
                QueueSession session = connection.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
                MessageProducer producer = session.createProducer(queue);                              
                
                TextMessage message = session.createTextMessage();
                
                message.setText(msg);           
                message.setJMSReplyTo(responseQueue);           
                
                
                producer.send(message);
                producer.close();
                connection.close();
                ///new session for receiving
                
                
                connection = connectionFactory.createQueueConnection();
                session = connection.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
                QueueReceiver consumer = session.createReceiver(responseQueue);
                
                
                Message reply = consumer.receive(1000); //wait max 500 ms for replay
                                
                
                if (reply != null)              
                        response.getWriter().print("Reply: " /*+ reply.getText()*/ );
                else
                        response.getWriter().print("No reply !!!");
                
                connection.close();
                } catch (Exception e) {
                        throw new ServletException(e);
                }
        }
        
        class Test implements MessageListener {

                @Override
                public void onMessage(Message message) {
                        // TODO Auto-generated method stub
                        System.out.println("onMessage() ");
                }
                
        }
}
1	package dk.thoerup.messagedriven;
2
3	import java.io.IOException;
4
5	import javax.annotation.Resource;
6	import javax.jms.Message;
7	import javax.jms.MessageListener;
8	import javax.jms.MessageProducer;
9	import javax.jms.Queue;
10	import javax.jms.QueueConnection;
11	import javax.jms.QueueConnectionFactory;
12	import javax.jms.QueueReceiver;
13	import javax.jms.QueueSession;
14	import javax.jms.Session;
15	import javax.jms.TextMessage;
16	import javax.servlet.ServletException;
17	import javax.servlet.annotation.WebServlet;
18	import javax.servlet.http.HttpServlet;
19	import javax.servlet.http.HttpServletRequest;
20	import javax.servlet.http.HttpServletResponse;
21
22	@WebServlet(name = "ReverserServlet", urlPatterns = { "/ReverserServlet" })
23	public class ReverserServlet extends HttpServlet {
24	private static final long serialVersionUID = 1L;
25
26	// resource mapped vars may of course not be static !
27	@Resource(mappedName = "jms/helloFactory")
28	private QueueConnectionFactory connectionFactory;
29
30	@Resource(mappedName = "jms/reverse")
31	private Queue queue;
32
33	@Resource(mappedName = "jms/reverseResponse")
34	private Queue responseQueue;
35
36
37
38	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
39	String msg = request.getParameter("msg");
40	if (msg == null)
41	msg = "Default";
42
43	try {
44
45
46	QueueConnection connection = connectionFactory.createQueueConnection();
47
48
49	QueueSession session = connection.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
50	MessageProducer producer = session.createProducer(queue);
51
52	TextMessage message = session.createTextMessage();
53
54	message.setText(msg);
55	message.setJMSReplyTo(responseQueue);
56
57
58	producer.send(message);
59	producer.close();
60	connection.close();
61	///new session for receiving
62
63
64	connection = connectionFactory.createQueueConnection();
65	session = connection.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
66	QueueReceiver consumer = session.createReceiver(responseQueue);
67
68
69
70	Message reply = consumer.receive(1000); //wait max 500 ms for replay
71
72
73	if (reply != null)
74	response.getWriter().print("Reply: " /+ reply.getText()/ );
75	else
76	response.getWriter().print("No reply !!!");
77
78	connection.close();
79	} catch (Exception e) {
80	throw new ServletException(e);
81	}
82	}
83
84	class Test implements MessageListener {
85
86	@Override
87	public void onMessage(Message message) {
88	// TODO Auto-generated method stub
89	System.out.println("onMessage() ");
90	}
91
92	}
93	}