/[projects]/miscJava/Test3/src/dk/thoerup/messagedriven/ProducerServlet.java
ViewVC logotype

Diff of /miscJava/Test3/src/dk/thoerup/messagedriven/ProducerServlet.java

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 1271 by torben, Wed Apr 6 21:41:41 2011 UTC revision 1273 by torben, Thu Apr 7 05:28:26 2011 UTC
# Line 2  package dk.thoerup.messagedriven; Line 2  package dk.thoerup.messagedriven;
2    
3  import java.io.IOException;  import java.io.IOException;
4    
5    import javax.annotation.Resource;
6  import javax.jms.Connection;  import javax.jms.Connection;
7  import javax.jms.ConnectionFactory;  import javax.jms.ConnectionFactory;
8  import javax.jms.MessageProducer;  import javax.jms.MessageProducer;
# Line 9  import javax.jms.Queue; Line 10  import javax.jms.Queue;
10  import javax.jms.Session;  import javax.jms.Session;
11  import javax.jms.TextMessage;  import javax.jms.TextMessage;
12  import javax.naming.InitialContext;  import javax.naming.InitialContext;
13    import javax.naming.NamingException;
14  import javax.servlet.ServletException;  import javax.servlet.ServletException;
15  import javax.servlet.annotation.WebServlet;  import javax.servlet.annotation.WebServlet;
16  import javax.servlet.http.HttpServlet;  import javax.servlet.http.HttpServlet;
# Line 20  import javax.servlet.http.HttpServletRes Line 22  import javax.servlet.http.HttpServletRes
22  public class ProducerServlet extends HttpServlet {  public class ProducerServlet extends HttpServlet {
23          private static final long serialVersionUID = 1L;          private static final long serialVersionUID = 1L;
24                
     /**  
      * @see HttpServlet#HttpServlet()  
      */  
     public ProducerServlet() {  
         super();  
         // TODO Auto-generated constructor stub  
     }  
25            
26      /* why doesn't these work ??      // why doesn't @Resource work ??
27      @Resource(mappedName = "jms/helloFactory")      @Resource(mappedName = "jms/helloFactory")
28      private static ConnectionFactory connectionFactory;      private static ConnectionFactory connectionFactory;
29    
30      @Resource(mappedName = "jms/hello")      @Resource(mappedName = "jms/hello")
31      private static Queue queue;      private static Queue queue;
32      */      
33    
34        @Override
35        public void init() throws ServletException {
36            
37            try {
38                    InitialContext ic = new InitialContext();
39                    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            } catch(NamingException ne) {
48                    throw new ServletException(ne);
49            }
50        }
51    
52    
53          protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {          protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
54                  try {                  try {
55                          InitialContext ic = new InitialContext();  
56                          ConnectionFactory cf = (ConnectionFactory)ic.lookup("jms/helloFactory");                          Connection connection = connectionFactory.createConnection();                  
                         Connection connection = cf.createConnection();  
                         Queue queue = (Queue)ic.lookup("jms/hello");  
57                                                    
                         //Connection connection = connectionFactory.createConnection();  
58                                    
59                  Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);                  Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
60                  MessageProducer producer = session.createProducer(queue);                  MessageProducer producer = session.createProducer(queue);
# Line 55  public class ProducerServlet extends Htt Line 64  public class ProducerServlet extends Htt
64                  producer.send(message);                  producer.send(message);
65                  response.getWriter().print("Message sent" );                  response.getWriter().print("Message sent" );
66                  } catch (Exception e) {                  } catch (Exception e) {
67                          response.getWriter().print("Error:" + e.getMessage() );                          throw new ServletException(e);
68                  }                  }
69          }          }
70    
Legend:
Removed from v.1271  
changed lines
  Added in v.1273
  ViewVC Help
Powered by ViewVC 1.1.20