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

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

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

revision 1276 by torben, Thu Apr 7 19:24:51 2011 UTC revision 1277 by torben, Thu Apr 7 19:44:38 2011 UTC
# Line 1  Line 1 
1  package dk.thoerup.messagedriven;  package dk.thoerup.messagedriven;
2    
3  import java.io.IOException;  import java.io.IOException;
4    import java.util.Random;
5    
6  import javax.annotation.Resource;  import javax.annotation.Resource;
7  import javax.jms.Message;  import javax.jms.Message;
# Line 40  public class ReverserServlet extends Htt Line 41  public class ReverserServlet extends Htt
41                  if (msg == null)                  if (msg == null)
42                          msg = "Default";                          msg = "Default";
43                                    
44                    Random r = new Random();
45                    
46                  try {                  try {
47                          QueueConnection connection = connectionFactory.createQueueConnection();                                          QueueConnection connection = connectionFactory.createQueueConnection();                
48                                                    
# Line 49  public class ReverserServlet extends Htt Line 52  public class ReverserServlet extends Htt
52                                    
53                  TextMessage message = session.createTextMessage();                  TextMessage message = session.createTextMessage();
54                                    
55                    String corrID = "" + r.nextInt();
56                    
57                  message.setText(msg);                            message.setText(msg);          
58                  message.setJMSReplyTo(responseQueue);                            message.setJMSReplyTo(responseQueue);          
59                    message.setJMSCorrelationID(corrID);
60                    
61                                                                    
62                  producer.send(message);                  producer.send(message);
63                                    
64                                    //Remember ' around the correleationID in JMS selector
65                  QueueReceiver consumer = session.createReceiver(responseQueue);                  QueueReceiver consumer = session.createReceiver(responseQueue,"JMSCorrelationID='" + corrID + "'");
66                  connection.start(); //incomming messages is not received until a start is given                  connection.start(); //incomming messages is not received until a start is given
67                                    
68                                    
Legend:
Removed from v.1276  
changed lines
  Added in v.1277
  ViewVC Help
Powered by ViewVC 1.1.20