Set any user properties on the request message

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@682326 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 14 insertions, 0 deletions

diff --git a/java/sca/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingInvoker.java b/java/sca/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingInvoker.java
index cb1ced3423..a5701f6d1b 100644
--- a/java/sca/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingInvoker.java
+++ b/java/sca/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingInvoker.java
@@ -19,6 +19,7 @@
 package org.apache.tuscany.sca.binding.jms.provider;
 
 import java.lang.reflect.InvocationTargetException;
+import java.util.Map;
 
 import javax.jms.DeliveryMode;
 import javax.jms.Destination;
@@ -334,6 +335,19 @@ public class JMSBindingInvoker implements Invoker, DataExchangeSemantics {
                 jmsMsg.setStringProperty(JMSBindingConstants.CALLBACK_Q_PROPERTY, callbackDestName);
             }
         }
+        
+        for (String propName : jmsBinding.getPropertyNames()) {
+            Object value = jmsBinding.getProperty(propName);
+            jmsMsg.setObjectProperty(propName, value);
+        }
+
+        Map<String, Object> operationProperties = jmsBinding.getOperationProperties(operationName);
+        if (operationProperties != null) {
+            for (String propName : operationProperties.keySet()) {
+                Object value = operationProperties.get(propName);
+                jmsMsg.setObjectProperty(propName, value);
+            }
+        }
     }
 
     protected boolean hasCallback() {