diff options
Diffstat (limited to '')
-rw-r--r-- | sca-java-2.x/trunk/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/headers/HeaderReferenceInterceptor.java | 7 |
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); |