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

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

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

revision 1276 by torben, Thu Apr 7 19:14:32 2011 UTC revision 1277 by torben, Thu Apr 7 19:44:38 2011 UTC
# Line 36  public class ReverserBean implements Mes Line 36  public class ReverserBean implements Mes
36                                  Queue q = (Queue) d;                                  Queue q = (Queue) d;
37                                                                    
38                                                                    
39                                  System.out.println("got Message - sending reply to " + q.getQueueName() );                                  System.out.println("got Message - sending reply to " + q.getQueueName() + " corrID=" + txt.getJMSCorrelationID());
40                                                                    
41                                                                    
42                                                                    
43                                  sendReply(msg,q);                                  sendReply(msg,q, txt.getJMSCorrelationID());
44                                                                    
45                                                                    
46                          }                          }
# Line 51  public class ReverserBean implements Mes Line 51  public class ReverserBean implements Mes
51                                                                    
52          }          }
53                    
54          private void sendReply(String msg, Queue dest) {          private void sendReply(String msg, Queue dest, String id) {
55                  try {                  try {
56                          InitialContext ic = new InitialContext();                          InitialContext ic = new InitialContext();
57                                    
# Line 65  public class ReverserBean implements Mes Line 65  public class ReverserBean implements Mes
65                          TextMessage reply = session.createTextMessage();                          TextMessage reply = session.createTextMessage();
66                          reply.setStringProperty("name", "reply");                          reply.setStringProperty("name", "reply");
67                          reply.setText(msg);                          reply.setText(msg);
68                            reply.setJMSCorrelationID(id);
69                          producer.send(reply);                          producer.send(reply);
70                                                    
71                          System.out.println("reply send messageid=" + reply.getJMSMessageID() );                          System.out.println("reply send messageid=" + reply.getJMSMessageID() );
Legend:
Removed from v.1276  
changed lines
  Added in v.1277
  ViewVC Help
Powered by ViewVC 1.1.20