You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tuscany.apache.org by an...@apache.org on 2008/08/04 13:22:17 UTC

svn commit: r682326 - /tuscany/java/sca/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingInvoker.java

Author: antelder
Date: Mon Aug  4 04:22:17 2008
New Revision: 682326

URL: http://svn.apache.org/viewvc?rev=682326&view=rev
Log:
Set any user properties on the request message

Modified:
    tuscany/java/sca/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingInvoker.java

Modified: tuscany/java/sca/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingInvoker.java
URL: http://svn.apache.org/viewvc/tuscany/java/sca/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingInvoker.java?rev=682326&r1=682325&r2=682326&view=diff
==============================================================================
--- tuscany/java/sca/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingInvoker.java (original)
+++ tuscany/java/sca/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingInvoker.java Mon Aug  4 04:22:17 2008
@@ -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 @@
                 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() {