/[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 1272 by torben, Thu Apr 7 05:24:58 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 21  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 @Resource 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      @Override
35      public void init() throws ServletException {      public void init() throws ServletException {
36            
37          try {          try {
38                  InitialContext ic = new InitialContext();                  InitialContext ic = new InitialContext();
39                  connectionFactory = (ConnectionFactory)ic.lookup("jms/helloFactory");                  if (connectionFactory == null) {
40                  queue = (Queue)ic.lookup("jms/hello");                          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) {          } catch(NamingException ne) {
48                  throw new ServletException(ne);                  throw new ServletException(ne);
49          }          }
# Line 54  public class ProducerServlet extends Htt Line 55  public class ProducerServlet extends Htt
55    
56                          Connection connection = connectionFactory.createConnection();                                            Connection connection = connectionFactory.createConnection();                  
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 64  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.1272  
changed lines
  Added in v.1273
  ViewVC Help
Powered by ViewVC 1.1.20