thoerup/messagedriven/ProducerServlet.java

package dk.thoerup.messagedriven;

import java.io.IOException;

import javax.annotation.Resource;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
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(name = "ProducerServlet", urlPatterns = { "/ProducerServlet" })
public class ProducerServlet extends HttpServlet {
        private static final long serialVersionUID = 1L;
       
    
    // why doesn't @Resource work ??
    @Resource(mappedName = "jms/helloFactory")
    private static ConnectionFactory connectionFactory;

    @Resource(mappedName = "jms/hello")
    private static Queue queue;
    

    @Override
    public void init() throws ServletException {
        
        try {
                InitialContext ic = new InitialContext();
                if (connectionFactory == null) {
                        connectionFactory = (ConnectionFactory)ic.lookup("jms/helloFactory");
                        System.out.println("@Resource failed for connection factory");
                }
                if (queue == null) {
                        queue = (Queue)ic.lookup("jms/hello");
                        System.out.println("@Resource failed for queue");
                }
        } catch(NamingException ne) {
                throw new ServletException(ne);
        }
    }


        protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
                try {

                        Connection connection = connectionFactory.createConnection();                   
                        
                
                Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
                MessageProducer producer = session.createProducer(queue);
                TextMessage message = session.createTextMessage();
                message.setStringProperty("name", "World!!");
                message.setText("this is the body");
                producer.send(message);
                response.getWriter().print("Message sent" );
                } catch (Exception e) {
                        throw new ServletException(e);
                }
        }


}
1	torben	1271	package dk.thoerup.messagedriven;
2
3			import java.io.IOException;
4
5	torben	1273	import javax.annotation.Resource;
6	torben	1271	import javax.jms.Connection;
7			import javax.jms.ConnectionFactory;
8			import javax.jms.MessageProducer;
9			import javax.jms.Queue;
10			import javax.jms.Session;
11			import javax.jms.TextMessage;
12			import javax.naming.InitialContext;
13	torben	1272	import javax.naming.NamingException;
14	torben	1271	import javax.servlet.ServletException;
15			import javax.servlet.annotation.WebServlet;
16			import javax.servlet.http.HttpServlet;
17			import javax.servlet.http.HttpServletRequest;
18			import javax.servlet.http.HttpServletResponse;
19
20
21			@WebServlet(name = "ProducerServlet", urlPatterns = { "/ProducerServlet" })
22			public class ProducerServlet extends HttpServlet {
23			private static final long serialVersionUID = 1L;
24
25
26	torben	1272	// why doesn't @Resource work ??
27	torben	1273	@Resource(mappedName = "jms/helloFactory")
28	torben	1271	private static ConnectionFactory connectionFactory;
29
30	torben	1273	@Resource(mappedName = "jms/hello")
31	torben	1271	private static Queue queue;
32	torben	1272
33	torben	1271
34	torben	1272	@Override
35			public void init() throws ServletException {
36	torben	1273
37	torben	1272	try {
38			InitialContext ic = new InitialContext();
39	torben	1273	if (connectionFactory == null) {
40			connectionFactory = (ConnectionFactory)ic.lookup("jms/helloFactory");
41			System.out.println("@Resource failed for connection factory");
42			}
43			if (queue == null) {
44			queue = (Queue)ic.lookup("jms/hello");
45			System.out.println("@Resource failed for queue");
46			}
47	torben	1272	} catch(NamingException ne) {
48			throw new ServletException(ne);
49			}
50			}
51	torben	1271
52
53			protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
54			try {
55	torben	1272
56			Connection connection = connectionFactory.createConnection();
57	torben	1271
58
59			Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
60			MessageProducer producer = session.createProducer(queue);
61			TextMessage message = session.createTextMessage();
62			message.setStringProperty("name", "World!!");
63			message.setText("this is the body");
64			producer.send(message);
65			response.getWriter().print("Message sent" );
66			} catch (Exception e) {
67	torben	1273	throw new ServletException(e);
68	torben	1271	}
69			}
70
71
72			}