summaryrefslogtreecommitdiffstats
path: root/java
diff options
context:
space:
mode:
Diffstat (limited to 'java')
-rw-r--r--java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/impl/JMSBindingProcessor.java8
-rw-r--r--java/sca/modules/binding-jms/src/test/java/org/apache/tuscany/sca/binding/jms/impl/JMSBindingProcessorTestCase.java2
2 files changed, 7 insertions, 3 deletions
diff --git a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/impl/JMSBindingProcessor.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/impl/JMSBindingProcessor.java
index 8a0e1b1096..1f07a07c08 100644
--- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/impl/JMSBindingProcessor.java
+++ b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/impl/JMSBindingProcessor.java
@@ -80,6 +80,10 @@ import org.apache.tuscany.sca.policy.PolicyFactory;
* </activationSpec>?
* </response>?
*
+ * <complexType name="SubscriptionHeaders">
+ * <attribute name="JMSSelector" type="string"/>
+ * </complexType>
+ *
* <resourceAdapter name="NMTOKEN">?
* <property name="NMTOKEN" type="NMTOKEN">*
* </resourceAdapter>?
@@ -237,8 +241,8 @@ public class JMSBindingProcessor implements StAXArtifactProcessor<JMSBinding> {
parseHeaders(reader, jmsBinding);
} else if ("operationProperties".equals(elementName)) {
parseOperationProperties(reader, jmsBinding);
- } else if ("subscriptionHeaders".equals(elementName)) {
- parseSubscriptionHeaders (reader, jmsBinding);
+ } else if ("SubscriptionHeaders".equals(elementName)) {
+ parseSubscriptionHeaders(reader, jmsBinding);
}
reader.next();
break;
diff --git a/java/sca/modules/binding-jms/src/test/java/org/apache/tuscany/sca/binding/jms/impl/JMSBindingProcessorTestCase.java b/java/sca/modules/binding-jms/src/test/java/org/apache/tuscany/sca/binding/jms/impl/JMSBindingProcessorTestCase.java
index 86f2a8fce8..7fe482c4f2 100644
--- a/java/sca/modules/binding-jms/src/test/java/org/apache/tuscany/sca/binding/jms/impl/JMSBindingProcessorTestCase.java
+++ b/java/sca/modules/binding-jms/src/test/java/org/apache/tuscany/sca/binding/jms/impl/JMSBindingProcessorTestCase.java
@@ -115,7 +115,7 @@ public class JMSBindingProcessorTestCase extends TestCase {
+ " <implementation.java class=\"services.HelloWorld\"/>"
+ " <service name=\"HelloWorldService\">"
+ " <binding.jms uri=\"jms:testQueue\" >"
- + " <subscriptionHeaders JMSSelector=\"prop1 = 2\" />"
+ + " <SubscriptionHeaders JMSSelector=\"prop1 = 2\" />"
+ " </binding.jms>"
+ " </service>"
+ " </component>"