From b26ca7d176a9df0e69aa59c0169e30e5bc5c0265 Mon Sep 17 00:00:00 2001 From: antelder Date: Mon, 4 Aug 2008 11:22:17 +0000 Subject: 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 --- .../sca/binding/jms/provider/JMSBindingInvoker.java | 14 ++++++++++++++ 1 file changed, 14 insertions(+) (limited to 'java') 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 operationProperties = jmsBinding.getOperationProperties(operationName); + if (operationProperties != null) { + for (String propName : operationProperties.keySet()) { + Object value = operationProperties.get(propName); + jmsMsg.setObjectProperty(propName, value); + } + } } protected boolean hasCallback() { -- cgit v1.2.3