1 files changed, 7 insertions, 0 deletions
diff --git a/sca-java-2.x/trunk/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/headers/HeaderReferenceInterceptor.java b/sca-java-2.x/trunk/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/headers/HeaderReferenceInterceptor.java
index 61c5dc8263..ad07655730 100644
--- a/sca-java-2.x/trunk/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/headers/HeaderReferenceInterceptor.java
+++ b/sca-java-2.x/trunk/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/headers/HeaderReferenceInterceptor.java
@@ -144,6 +144,13 @@ public class HeaderReferenceInterceptor implements Interceptor {
             	context.setTimeToLive(JMSBindingConstants.DEFAULT_TIME_TO_LIVE);        
             }
             
+            // Adding MESSAGE_ID field to the JMS message, which is used to correlate async callbacks
+            String msgID = (String)tuscanyMsg.getHeaders().get("MESSAGE_ID");
+            if( msgID != null ) {
+            	jmsMsg.setObjectProperty("MESSAGE_ID", msgID);
+            } // end if 
+            //
+            
             return tuscanyMsg;
         } catch (JMSException e) {
             throw new JMSBindingException(e);