Add support for operation property properties to binding.jms

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

2 files changed, 40 insertions, 15 deletions

diff --git a/branches/sca-java-1.x/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/impl/JMSBinding.java b/branches/sca-java-1.x/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/impl/JMSBinding.java
index fcb640398d..e804d5058c 100644
--- a/branches/sca-java-1.x/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/impl/JMSBinding.java
+++ b/branches/sca-java-1.x/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/impl/JMSBinding.java
@@ -119,6 +119,8 @@ public class JMSBinding implements BindingRRB, PolicySetAttachPoint {
     private Map<String, Boolean> operationJMSDeliveryModes = new HashMap<String, Boolean>();
     private Map<String, Long> operationJMSTimeToLives = new HashMap<String, Long>();
     private Map<String, Integer> operationJMSPriorities = new HashMap<String, Integer>();
+    private Map<String, Map<String, BindingProperty>> operationPropertiesProperties = new HashMap<String, Map<String,BindingProperty>>();
+
     private String jmsSelector;
     private String requestConnectionName;
     private String responseConnectionName;
@@ -645,4 +647,11 @@ public class JMSBinding implements BindingRRB, PolicySetAttachPoint {
         return responseConnectionFactoryProperties;
     }
 
+    public Map<String, BindingProperty> getOperationPropertiesProperties(String opName) {
+        if (operationPropertiesProperties.get(opName)==null) {
+            operationPropertiesProperties.put(opName, new HashMap<String, BindingProperty>());
+        }
+        return operationPropertiesProperties.get(opName);
+    }
+
 }
diff --git a/branches/sca-java-1.x/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/impl/JMSBindingProcessor.java b/branches/sca-java-1.x/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/impl/JMSBindingProcessor.java
index eb50c11843..b7540e804d 100644
--- a/branches/sca-java-1.x/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/impl/JMSBindingProcessor.java
+++ b/branches/sca-java-1.x/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/impl/JMSBindingProcessor.java
@@ -620,14 +620,24 @@ public class JMSBindingProcessor implements StAXArtifactProcessor<JMSBinding> {
                 case START_ELEMENT:
                     if (reader.getName().getLocalPart().equals("headers")) {
                         parseOperationHeaders(reader, jmsBinding, opName);
+                    } else if (reader.getName().getLocalPart().equals("property")) {
+                        jmsBinding.getOperationPropertiesProperties(opName).putAll(parseBindingProperties(reader));
                     }
-                    break;
+//                    break;
                 case END_ELEMENT:
-                    QName x = reader.getName();
-                    if (x.getLocalPart().equals("operationProperties")) {
-                        return;
-                    } else {
-                        error("UnexpectedResponseElement", reader, x.toString());
+                    if (reader.isEndElement()) {
+                        QName x = reader.getName();
+                        if (x.getLocalPart().equals("headers")) {
+                            break;
+                        }
+                        if (x.getLocalPart().equals("property")) {
+                            break;
+                        }
+                        if (x.getLocalPart().equals("operationProperties")) {
+                            return;
+                        } else {
+                            error("UnexpectedResponseElement", reader, x.toString());
+                        }
                     }
             }
         }
@@ -723,18 +733,14 @@ public class JMSBindingProcessor implements StAXArtifactProcessor<JMSBinding> {
 
     private Map<String, BindingProperty> parseBindingProperties(XMLStreamReader reader) throws XMLStreamException {
         Map<String, BindingProperty> props = new HashMap<String, BindingProperty>();
+        if ("property".equals(reader.getName().getLocalPart())) {
+            processProperty(reader, props);
+        }
         while (true) {
             switch (reader.next()) {
                 case START_ELEMENT:
-                    String elementName = reader.getName().getLocalPart();
-                    if ("property".equals(elementName)) {
-                        String name = reader.getAttributeValue(null, "name");
-                        if (name == null || name.length() < 1) {
-                            error("InvalidPropertyElement", reader, elementName);
-                        }
-                        String type = reader.getAttributeValue(null, "type");
-                        String value = reader.getElementText();
-                        props.put(name, new BindingProperty(name, type, value));
+                    if ("property".equals(reader.getName().getLocalPart())) {
+                        processProperty(reader, props);
                     }
                     break;
                 case END_ELEMENT:
@@ -743,6 +749,16 @@ public class JMSBindingProcessor implements StAXArtifactProcessor<JMSBinding> {
         }
     }
 
+    private void processProperty(XMLStreamReader reader, Map<String, BindingProperty> props) throws XMLStreamException {
+        String name = reader.getAttributeValue(null, "name");
+        if (name == null || name.length() < 1) {
+            error("InvalidPropertyElement", reader);
+        }
+        String type = reader.getAttributeValue(null, "type");
+        String value = reader.getElementText();
+        props.put(name, new BindingProperty(name, type, value));
+    }
+
     /**
      * Preserve an existing public method. The method validate() is a legacy method 
      * that was called from reading am XML stream via the read(XMLStreamReader) method above.