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 |
} |
} |
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 |
|
|
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() ); |