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.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;
       
    
    // resource mapped vars may of course not be static !
    @Resource(mappedName = "jms/helloFactory")
    private ConnectionFactory connectionFactory;

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