--- miscJava/Test3/src/dk/thoerup/messagedriven/ReverserBean.java	2011/04/07 19:24:51	1276
+++ miscJava/Test3/src/dk/thoerup/messagedriven/ReverserBean.java	2011/04/07 19:44:38	1277
@@ -36,11 +36,11 @@
 				Queue q = (Queue) d;
 				
 				
-				System.out.println("got Message - sending reply to " + q.getQueueName() );
+				System.out.println("got Message - sending reply to " + q.getQueueName() + " corrID=" + txt.getJMSCorrelationID());
 				
 				
 				
-				sendReply(msg,q);
+				sendReply(msg,q, txt.getJMSCorrelationID());
 				
 				
 			}
@@ -51,7 +51,7 @@
 				
 	} 
 	
-	private void sendReply(String msg, Queue dest) {
+	private void sendReply(String msg, Queue dest, String id) {
 		try {
 			InitialContext ic = new InitialContext();
 		
@@ -65,6 +65,7 @@
 			TextMessage reply = session.createTextMessage();
 			reply.setStringProperty("name", "reply");
 			reply.setText(msg);
+			reply.setJMSCorrelationID(id);
 			producer.send(reply);
 			
 			System.out.println("reply send messageid=" + reply.getJMSMessageID() );