/[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 1274 by torben, Thu Apr 7 17:31:04 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;
9  import javax.jms.Queue;  import javax.jms.Queue;
10  import javax.jms.Session;  import javax.jms.Session;
11  import javax.jms.TextMessage;  import javax.jms.TextMessage;
 import javax.naming.InitialContext;  
12  import javax.servlet.ServletException;  import javax.servlet.ServletException;
13  import javax.servlet.annotation.WebServlet;  import javax.servlet.annotation.WebServlet;
14  import javax.servlet.http.HttpServlet;  import javax.servlet.http.HttpServlet;
# Line 20  import javax.servlet.http.HttpServletRes Line 20  import javax.servlet.http.HttpServletRes
20  public class ProducerServlet extends HttpServlet {  public class ProducerServlet extends HttpServlet {
21          private static final long serialVersionUID = 1L;          private static final long serialVersionUID = 1L;
22                
     /**  
      * @see HttpServlet#HttpServlet()  
      */  
     public ProducerServlet() {  
         super();  
         // TODO Auto-generated constructor stub  
     }  
23            
24      /* why doesn't these work ??      // resource mapped vars may of course not be static !
25      @Resource(mappedName = "jms/helloFactory")      @Resource(mappedName = "jms/helloFactory")
26      private static ConnectionFactory connectionFactory;      private ConnectionFactory connectionFactory;
27    
28      @Resource(mappedName = "jms/hello")      @Resource(mappedName = "jms/hello")
29      private static Queue queue;      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 {          protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
52                  try {                  try {
53                          InitialContext ic = new InitialContext();  
54                          ConnectionFactory cf = (ConnectionFactory)ic.lookup("jms/helloFactory");                          Connection connection = connectionFactory.createConnection();                  
                         Connection connection = cf.createConnection();  
                         Queue queue = (Queue)ic.lookup("jms/hello");  
55                                                    
                         //Connection connection = connectionFactory.createConnection();  
56                                    
57                  Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);                  Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
58                  MessageProducer producer = session.createProducer(queue);                  MessageProducer producer = session.createProducer(queue);
# Line 55  public class ProducerServlet extends Htt Line 62  public class ProducerServlet extends Htt
62                  producer.send(message);                  producer.send(message);
63                  response.getWriter().print("Message sent" );                  response.getWriter().print("Message sent" );
64                  } catch (Exception e) {                  } catch (Exception e) {
65                          response.getWriter().print("Error:" + e.getMessage() );                          throw new ServletException(e);
66                  }                  }
67          }          }
68    
Legend:
Removed from v.1271  
changed lines
  Added in v.1274
  ViewVC Help
Powered by ViewVC 1.1.20