Moving 2.x trunk

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

25 files changed, 4246 insertions, 0 deletions

diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/BindingProperty.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/BindingProperty.java
new file mode 100644
index 0000000000..c195a16ce5
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/BindingProperty.java
@@ -0,0 +1,71 @@
+/*

+ * Licensed to the Apache Software Foundation (ASF) under one

+ * or more contributor license agreements.  See the NOTICE file

+ * distributed with this work for additional information

+ * regarding copyright ownership.  The ASF licenses this file

+ * to you under the Apache License, Version 2.0 (the

+ * "License"); you may not use this file except in compliance

+ * with the License.  You may obtain a copy of the License at

+ * 

+ *   http://www.apache.org/licenses/LICENSE-2.0

+ * 

+ * Unless required by applicable law or agreed to in writing,

+ * software distributed under the License is distributed on an

+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY

+ * KIND, either express or implied.  See the License for the

+ * specific language governing permissions and limitations

+ * under the License.    

+ */

+

+package org.apache.tuscany.sca.binding.jms;

+

+public class BindingProperty {

+    

+    private String name;

+    private String type;

+    private Object value;

+    

+    public BindingProperty(String name, String type, Object value) {

+        this.name = name;

+        this.type = type;

+        this.value = value;

+    }

+

+    public String getName() {

+        return name;

+    }

+

+    public String getType() {

+        return type;

+    }

+    

+    public Object getValue() {

+        return value;

+    }

+    

+    @Override

+    public boolean equals( Object object ) {

+        return ( object instanceof BindingProperty ) && equals( (BindingProperty) object );

+    }

+

+    /**

+     * Test whether this and another Binding Property are equal.

+     * @param property

+     * @return true if all fields of property match.

+     */

+    public boolean equals( BindingProperty property ) {

+        if ( name == null && property.getName() != null )

+            return false;

+        else if ( !name.equals( property.getName() ))

+            return false;

+        else if ( type == null && property.getType() != null )

+            return false;

+        else if ( !type.equals( property.getType() ))

+            return false;

+        else if ( value == null && property.getValue() != null )

+            return false;

+        else if ( !value.equals( property.getValue() ))

+                return false;

+        return true;

+    }

+}

diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBinding.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBinding.java
new file mode 100644
index 0000000000..8e6684b44d
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBinding.java
@@ -0,0 +1,974 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.TreeSet;
+
+import javax.xml.namespace.QName;
+
+import org.apache.tuscany.sca.assembly.BindingRRB;
+import org.apache.tuscany.sca.assembly.ConfiguredOperation;
+import org.apache.tuscany.sca.assembly.OperationSelector;
+import org.apache.tuscany.sca.assembly.OperationsConfigurator;
+import org.apache.tuscany.sca.assembly.WireFormat;
+import org.apache.tuscany.sca.policy.ExtensionType;
+import org.apache.tuscany.sca.policy.Intent;
+import org.apache.tuscany.sca.policy.PolicySet;
+import org.apache.tuscany.sca.policy.PolicySubject;
+
+/**
+ * Models a binding to a JMS resource.
+ *
+ * @version $Rev$ $Date$
+ */
+
+//public class JMSBinding implements BindingRRB, PolicySubject, OperationsConfigurator, DefinitionElement {
+public class JMSBinding implements BindingRRB, PolicySubject, OperationsConfigurator {
+    QName TYPE = new QName(SCA11_NS, "binding.jms");
+
+    @Override
+    public Object clone() throws CloneNotSupportedException {
+        return super.clone();
+    }
+
+    // properties required to implement the Tuscany binding extension SPI
+    private String uri = null;
+    private String name = null;
+    private boolean unresolved = false;
+    private List<Object> extensions = new ArrayList<Object>();
+    
+    // properties required by PolicySetAttachPoint
+    private List<PolicySet> policySets = new ArrayList<PolicySet>();
+    private List<PolicySet> applicablePolicySets = new ArrayList<PolicySet>();
+    
+    // properties required by IntentAttachPoint 
+    private List<Intent> requiredIntents = new ArrayList<Intent>();
+
+    // properties required to describe configured operations
+    private List<ConfiguredOperation>  configuredOperations = new ArrayList<ConfiguredOperation>();
+    
+    // properties required by DefinitionElement @575803A
+    private String targetNamespace;
+
+    // Properties required to describe the JMS binding model
+
+    private String correlationScheme = JMSBindingConstants.CORRELATE_MSG_ID;
+    private String initialContextFactoryName;
+    private String jndiURL;
+
+    private String destinationName = null;
+    private String destinationType = JMSBindingConstants.DESTINATION_TYPE_QUEUE;
+    private String destinationCreate = JMSBindingConstants.CREATE_IF_NOT_EXIST;
+    private Map<String, BindingProperty> destinationProperties = new HashMap<String, BindingProperty>();
+
+    private String connectionFactoryName = null;
+    private String connectionFactoryCreate = JMSBindingConstants.CREATE_IF_NOT_EXIST;
+    private Map<String, BindingProperty> connectionFactoryProperties = new HashMap<String, BindingProperty>();
+
+    private String activationSpecName = null;
+    private String activationSpecCreate = null;
+    private Map<String, BindingProperty> activationSpecProperties = new HashMap<String, BindingProperty>();
+
+    private String resourceAdapterName;;
+    private Map<String, BindingProperty> resourceAdapterProperties = new HashMap<String, BindingProperty>();
+    
+    private String responseActivationSpecName = null;
+    private String responseActivationSpecCreate = null;
+    private Map<String, BindingProperty> responseActivationSpecProperties = new HashMap<String, BindingProperty>();
+
+    private String responseDestinationName = null;
+    private String responseDestinationType = JMSBindingConstants.DESTINATION_TYPE_QUEUE;
+    private String responseDestinationCreate = JMSBindingConstants.CREATE_IF_NOT_EXIST;
+    private Map<String, BindingProperty> responseDestinationProperties = new HashMap<String, BindingProperty>();
+
+    private String responseConnectionFactoryName = null;
+    private String responseConnectionFactoryCreate = JMSBindingConstants.CREATE_IF_NOT_EXIST;
+    private Map<String, BindingProperty> responseConnectionFactoryProperties = new HashMap<String, BindingProperty>();
+
+    // Provides the name of the factory that interfaces to the JMS API for us.
+    private String jmsResourceFactoryName = JMSBindingConstants.DEFAULT_RF_CLASSNAME;
+
+    // Message processors used to deal with the request and response messages
+    public String requestMessageProcessorName = JMSBindingConstants.DEFAULT_MP_CLASSNAME;
+    public String responseMessageProcessorName = JMSBindingConstants.DEFAULT_MP_CLASSNAME;
+
+    // The JMS message property used to hold the name of the operation being called
+    private String operationSelectorPropertyName = JMSBindingConstants.DEFAULT_OPERATION_PROP_NAME;
+
+    // If the operation selector is derived automatically from the service interface it's stored here
+    private String operationSelectorName = null;
+
+    private boolean containsHeaders = false;
+    private String replyTo;
+    private String jmsType;
+    private String jmsCorrelationId;
+    private Boolean deliveryModePersistent;
+    private Long timeToLive;
+    private Integer jmsPriority;
+
+    private Map<String, Object> properties = new HashMap<String, Object>();
+    private Map<String, Map<String, Object>> operationProperties = new HashMap<String, Map<String,Object>>();
+    private Map<String, String> nativeOperationNames = new HashMap<String, String>();
+    private Map<String, String> operationJMSTypes = new HashMap<String, String>();
+    private Map<String, String> operationJMSCorrelationIds = new HashMap<String, String>();
+    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 QName requestConnectionName;
+    private QName responseConnectionName;
+    private QName operationPropertiesName;
+    private JMSBinding requestConnectionBinding;
+    private JMSBinding responseConnectionBinding;
+    private JMSBinding operationPropertiesBinding;
+    
+    private WireFormat requestWireFormat;
+    private WireFormat responseWireFormat;
+    private OperationSelector operationSelector;
+    private ExtensionType extensionType;
+    
+    public JMSBinding() {
+        super();
+    }
+
+    // operations required by Binding 
+    public String getURI() {
+        return this.uri;
+    }
+
+    public void setURI(String uri) {
+        this.uri = uri;
+    }
+
+    public String getName() {
+        return this.name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public boolean isUnresolved() {
+        return this.unresolved;
+    }
+
+    public void setUnresolved(boolean unresolved) {
+        this.unresolved = unresolved;
+    }
+
+    public List<Object> getExtensions() {
+        return extensions;
+    }
+    
+    public WireFormat getRequestWireFormat() {
+        return requestWireFormat;
+    }
+    
+    public void setRequestWireFormat(WireFormat wireFormat) {
+        this.requestWireFormat = wireFormat;
+    }
+    
+    public WireFormat getResponseWireFormat() {
+        return responseWireFormat;
+    }
+    
+    public void setResponseWireFormat(WireFormat wireFormat) {
+        this.responseWireFormat = wireFormat;
+    }    
+    
+    public OperationSelector getOperationSelector() {
+        return operationSelector;
+    }
+    
+    public void setOperationSelector(OperationSelector operationSelector) {
+        this.operationSelector = operationSelector;
+    }
+
+    // Methods for getting/setting JMS binding model information
+    // as derived from the XML of the binding.jms element
+
+    public void setCorrelationScheme(String correlationScheme) {
+        this.correlationScheme = correlationScheme;
+    }
+
+    public String getCorrelationScheme() {
+        return correlationScheme;
+    }
+
+    public String getInitialContextFactoryName() {
+        return initialContextFactoryName;
+    }
+
+    public void setInitialContextFactoryName(String initialContextFactoryName) {
+        this.initialContextFactoryName = initialContextFactoryName;
+    }
+
+    public String getJndiURL() {
+        return this.jndiURL;
+    }
+
+    public void setJndiURL(String jndiURL) {
+        this.jndiURL = jndiURL;
+    }
+
+    public String getDestinationName() {
+        if (requestConnectionBinding != null && requestConnectionBinding.getDestinationName() != null) {
+            return requestConnectionBinding.getDestinationName();
+        } else {
+            return destinationName;
+        }
+    }
+
+    public void setDestinationName(String destinationName) {
+        this.destinationName = destinationName;
+    }
+
+    public String getDestinationType() {
+        if (requestConnectionBinding != null && requestConnectionBinding.getDestinationType() != null) {
+            return requestConnectionBinding.getDestinationType();
+        } else {
+            return destinationType;
+        }
+    }
+
+    public void setDestinationType(String destinationType) {
+        this.destinationType = destinationType;
+    }
+
+    public String getDestinationCreate() {
+        if (requestConnectionBinding != null && requestConnectionBinding.getDestinationCreate() != null) {
+            return requestConnectionBinding.getDestinationCreate();
+        } else {
+            return this.destinationCreate;
+        }
+    }
+
+    public void setDestinationCreate(String create) {
+        this.destinationCreate = create;
+    }
+
+    public String getConnectionFactoryName() {
+        if (requestConnectionBinding != null && requestConnectionBinding.getConnectionFactoryName() != null) {
+            return requestConnectionBinding.getConnectionFactoryName();
+        } else {
+            return connectionFactoryName;
+        }
+    }
+
+    public void setConnectionFactoryName(String connectionFactoryName) {
+        this.connectionFactoryName = connectionFactoryName;
+    }
+
+    public String getConnectionFactoryCreate() {
+        if (requestConnectionBinding != null && requestConnectionBinding.getConnectionFactoryCreate() != null) {
+            return requestConnectionBinding.getConnectionFactoryCreate();
+        } else {
+            return this.connectionFactoryCreate;
+        }
+    }
+
+    public void setConnectionFactoryCreate(String create) {
+        this.connectionFactoryCreate = create;
+    }
+
+    public String getResourceAdapterName() {
+        return resourceAdapterName;
+    }
+
+    public void setResourceAdapterName(String name) {
+        resourceAdapterName = name;
+    }
+
+    public String getActivationSpecName() {
+        if (requestConnectionBinding != null && requestConnectionBinding.getActivationSpecName() != null) {
+            return requestConnectionBinding.getActivationSpecName();
+        } else {
+            return activationSpecName;
+        }
+    }
+
+    public void setActivationSpecName(String activationSpecName) {
+        this.activationSpecName = activationSpecName;
+    }
+
+    public String getActivationSpecCreate() {
+        if (requestConnectionBinding != null && requestConnectionBinding.getActivationSpecCreate() != null) {
+            return requestConnectionBinding.getActivationSpecCreate();
+        } else {
+            return this.activationSpecCreate;
+        }
+    }
+
+    public void setActivationSpecCreate(String create) {
+        this.activationSpecCreate = create;
+    }
+
+    public String getResponseDestinationName() {
+        if (requestConnectionBinding != null && requestConnectionBinding.getResponseDestinationName() != null) {
+            return requestConnectionBinding.getResponseDestinationName();
+        } else {
+            return this.responseDestinationName;
+        }
+    }
+
+    public void setResponseDestinationName(String name) {
+        this.responseDestinationName = name;
+    }
+
+    public String getResponseDestinationType() {
+        if (requestConnectionBinding != null && requestConnectionBinding.getResponseDestinationType() != null) {
+            return requestConnectionBinding.getResponseDestinationType();
+        } else {
+            return this.responseDestinationType;
+        }
+    }
+
+    public void setResponseDestinationType(String type) {
+        this.responseDestinationType = type;
+    }
+
+    public String getResponseDestinationCreate() {
+        if (requestConnectionBinding != null && requestConnectionBinding.getResponseDestinationCreate() != null) {
+            return requestConnectionBinding.getResponseDestinationCreate();
+        } else {
+            return this.responseDestinationCreate;
+        }
+    }
+
+    public void setResponseDestinationCreate(String create) {
+        this.responseDestinationCreate = create;
+    }
+
+    public String getResponseConnectionFactoryName() {
+        if (requestConnectionBinding != null && requestConnectionBinding.getResponseConnectionFactoryName() != null) {
+            return requestConnectionBinding.getResponseConnectionFactoryName();
+        } else {
+            return responseConnectionFactoryName;
+        }
+    }
+
+    public void setResponseConnectionFactoryName(String connectionFactoryName) {
+        this.responseConnectionFactoryName = connectionFactoryName;
+    }
+
+    public String getResponseConnectionFactoryCreate() {
+        if (requestConnectionBinding != null && requestConnectionBinding.getResponseConnectionFactoryCreate() != null) {
+            return requestConnectionBinding.getResponseConnectionFactoryCreate();
+        } else {
+            return this.responseConnectionFactoryCreate;
+        }
+    }
+
+    public void setResponseConnectionFactoryCreate(String create) {
+        this.responseConnectionFactoryCreate = create;
+    }
+
+    public String getResponseActivationSpecName() {
+        if (requestConnectionBinding != null && requestConnectionBinding.getResponseActivationSpecName() != null) {
+            return requestConnectionBinding.getResponseActivationSpecName();
+        } else {
+            return responseActivationSpecName;
+        }
+    }
+
+    public void setResponseActivationSpecName(String activationSpecName) {
+        this.responseActivationSpecName = activationSpecName;
+    }
+
+    public String getResponseActivationSpecCreate() {
+        if (requestConnectionBinding != null && requestConnectionBinding.getResponseActivationSpecCreate() != null) {
+            return requestConnectionBinding.getResponseActivationSpecCreate();
+        } else {
+            return this.responseActivationSpecCreate;
+        }
+    }
+
+    public void setResponseActivationSpecCreate(String create) {
+        this.responseActivationSpecCreate = create;
+    }
+
+    public String getJmsResourceFactoryName() {
+        return jmsResourceFactoryName;
+    }
+
+    public void setJmsResourceFactoryName(String jmsResourceFactoryName) {
+        this.jmsResourceFactoryName = jmsResourceFactoryName;
+    }
+
+    public void setRequestMessageProcessorName(String name) {
+        this.requestMessageProcessorName = name;
+    }
+
+    public String getRequestMessageProcessorName() {
+        return requestMessageProcessorName;
+    }
+
+    public void setResponseMessageProcessorName(String name) {
+        this.responseMessageProcessorName = name;
+    }
+
+    public String getResponseMessageProcessorName() {
+        return responseMessageProcessorName;
+    }
+
+    public String getOperationSelectorPropertyName() {
+        return operationSelectorPropertyName;
+    }
+
+    public void setOperationSelectorPropertyName(String operationSelectorPropertyName) {
+        this.operationSelectorPropertyName = operationSelectorPropertyName;
+    }
+
+    public String getOperationSelectorName() {
+        return operationSelectorName;
+    }
+
+    public void setOperationSelectorName(String operationSelectorName) {
+        this.operationSelectorName = operationSelectorName;
+    }
+
+    public void setHeaders( boolean containsHeaders ) {
+        this.containsHeaders = containsHeaders;
+    }
+
+    public boolean containsHeaders() {
+        return this.containsHeaders;
+    }
+
+    public String getReplyTo() {
+        return replyTo;
+    }
+
+    public void setReplyTo(String replyTo) {
+        this.replyTo = replyTo;
+    }
+
+    public String getJMSType() {
+        return jmsType;
+    }
+    public void setJMSType(String jmsType) {
+        setHeaders( true );
+        this.jmsType = jmsType;
+    }
+
+    public String getJMSCorrelationId() {
+        return jmsCorrelationId;
+    }
+    
+    public void setJMSCorrelationId(String jmsCorrelationId) {
+        setHeaders( true );
+        this.jmsCorrelationId = jmsCorrelationId;
+    }
+
+    public Boolean isdeliveryModePersistent() {
+        return deliveryModePersistent;
+    }
+    public void setJMSDeliveryMode(boolean persistent) {
+        setHeaders( true );
+        this.deliveryModePersistent = Boolean.valueOf(persistent);
+    }
+
+    public Integer getJMSPriority() {
+        return jmsPriority;
+    }
+
+    public void setJMSPriority(int jmsPriority) {
+        setHeaders( true );
+        this.jmsPriority = Integer.valueOf(jmsPriority);
+    }
+
+    public Long getJMSTimeToLive() {
+        return timeToLive;
+    }
+
+    public void setJMSTimeToLive(long timeToLive) {
+        setHeaders( true );
+        this.timeToLive = Long.valueOf(timeToLive);
+    }
+
+    public Set<String> getPropertyNames() {
+        return properties.keySet();
+    }
+
+    public Object getProperty(String name) {
+        return properties.get(name);
+    }
+
+    public void setProperty(String name, Object value) {
+        properties.put(name, value);
+    }
+
+    protected Map<String, Object> getProperties() {
+        return properties;
+    }
+    
+    /**
+     * Adds an operationName to this binding.
+     * @param opName
+     */
+    public void addOperationName(String opName) {
+        Map<String, Object> props = operationProperties.get(opName);
+        if (props == null) {
+            props = new HashMap<String, Object>();
+            operationProperties.put(opName, props);
+        }
+    }
+    
+    /**
+     * Provides set of operation names in this binding.
+     * @return a Set<String> of operation names
+     */
+    public Set<String> getOperationNames() {
+        if (operationPropertiesBinding != null) {
+            return operationPropertiesBinding.getOperationNames();
+        } else {
+            // Make a defensive copy since key changes affect map, map changes affect keys.
+            Set<String> opNames = operationProperties.keySet();
+            Set<String> opNamesCopy = new TreeSet<String>( opNames );
+            return opNamesCopy;
+        }
+    }
+    
+    public Map<String, Object> getOperationProperties(String opName) {
+        if (operationPropertiesBinding != null) {
+            return operationPropertiesBinding.getOperationProperties(opName);
+        } else {
+            return operationProperties.get(opName);
+        }
+    }
+
+    public void setOperationProperty(String opName, String propName, Object value) {
+        Map<String, Object> props = operationProperties.get(opName);
+        if (props == null) {
+            props = new HashMap<String, Object>();
+            operationProperties.put(opName, props);
+        }
+        props.put(propName, value);
+    }
+
+    /**
+     * Provides the value of a property for a given operation
+     * @param opName is the name of the operation in this binding.
+     * @param propName is the key name for the property
+     * @return Object representing the property value for this property name. Returns
+     * null for non existant operation name or property name.
+     */
+    public Object getOperationProperty(String opName, String propName ) {
+        if (operationPropertiesBinding != null) {
+            return operationPropertiesBinding.getOperationProperty(opName, propName);
+        } else {
+            Map<String, Object> props = operationProperties.get(opName);
+            if (props == null) { 
+                return null;
+            }
+            return props.get(propName);
+        }
+    }
+
+    public boolean hasNativeOperationName(String opName) {
+        if (operationPropertiesBinding != null) {
+            return operationPropertiesBinding.hasNativeOperationName(opName);
+        } else {
+            return nativeOperationNames.containsKey(opName);
+        }
+    }
+
+    public String getNativeOperationName(String opName) {
+        if (operationPropertiesBinding != null && operationPropertiesBinding.getNativeOperationName(opName) != null) {
+            return operationPropertiesBinding.getNativeOperationName(opName);
+        } else {
+            if (nativeOperationNames.containsKey(opName)) {
+                return nativeOperationNames.get(opName);
+            } else {
+                return opName;
+            }
+        }
+    }
+
+    public void setNativeOperationName(String opName, String nativeOpName) {
+        this.nativeOperationNames .put(opName, nativeOpName);
+    }
+
+    public String getOperationJMSType(String opName) {
+        if (operationPropertiesBinding != null && operationPropertiesBinding.getOperationJMSType(opName) != null) {
+            return operationPropertiesBinding.getOperationJMSType(opName);
+        } else {
+            if (operationJMSTypes.containsKey(opName)) {
+                return operationJMSTypes.get(opName);
+            } else {
+                return jmsType;
+            }
+        }
+    }
+    public void setOperationJMSType(String opName, String jmsType) {
+        this.operationJMSTypes.put(opName, jmsType);
+    }
+
+    public String getOperationJMSCorrelationId(String opName) {
+        if (operationPropertiesBinding != null) {
+            if (operationPropertiesBinding.getOperationJMSCorrelationId(opName) != null) {
+                return operationPropertiesBinding.getOperationJMSCorrelationId(opName);
+            } else {
+                return jmsCorrelationId;
+            }
+        } else {
+            if (operationJMSCorrelationIds.containsKey(opName)) {
+                return operationJMSCorrelationIds.get(opName);
+            } else {
+                return jmsCorrelationId;
+            }
+        }
+    }
+    public void setOperationJMSCorrelationId(String opName, String jmsCorrelationId) {
+        operationJMSCorrelationIds.put(opName, jmsCorrelationId);
+    }
+
+    public Boolean getOperationJMSDeliveryMode(String opName) {
+        if (operationPropertiesBinding != null) {
+            if (operationPropertiesBinding.getOperationJMSDeliveryMode(opName) != null) {
+                return operationPropertiesBinding.getOperationJMSDeliveryMode(opName);
+            } else {
+                return deliveryModePersistent;
+            }
+        } else {
+            if (operationJMSDeliveryModes.containsKey(opName)) {
+                return operationJMSDeliveryModes.get(opName);
+            } else {
+                return deliveryModePersistent;
+            }
+        }
+    }
+    public void setOperationJMSDeliveryMode(String opName, boolean b) {
+        operationJMSDeliveryModes.put(opName, b);
+    }
+
+    public Long getOperationJMSTimeToLive(String opName) {
+        if (operationPropertiesBinding != null) {
+            if (operationPropertiesBinding.getOperationJMSTimeToLive(opName) != null) {
+                return operationPropertiesBinding.getOperationJMSTimeToLive(opName);
+            } else {
+                return timeToLive;
+            }
+        } else {
+            if (operationJMSTimeToLives.containsKey(opName)) {
+                return operationJMSTimeToLives.get(opName);
+            } else {
+                return timeToLive;
+            }
+        }
+    }
+    public void setOperationJMSTimeToLive(String opName, Long ttl) {
+        operationJMSTimeToLives.put(opName, ttl);
+    }
+
+    public Integer getOperationJMSPriority(String opName) {
+        if (operationPropertiesBinding != null) {
+            if (operationPropertiesBinding.getOperationJMSPriority(opName) != null) {
+                return operationPropertiesBinding.getOperationJMSPriority(opName);
+            } else {
+                return jmsPriority;
+            }
+        } else {
+            if (operationJMSPriorities.containsKey(opName)) {
+                return operationJMSPriorities.get(opName);
+            } else {
+                return jmsPriority;
+            }
+        }
+    }
+    public void setOperationJMSPriority(String opName, int p) {
+        operationJMSPriorities.put(opName, p);
+    }
+
+    public String getJMSSelector() {
+        return jmsSelector;
+    }
+    public void setJMSSelector(String jmsSelector) {
+        this.jmsSelector = jmsSelector;
+    }
+
+    public QName getRequestConnectionName() {
+        return requestConnectionName;
+    }
+
+    public void setRequestConnectionName(QName requestConnectionName) {
+        this.requestConnectionName = requestConnectionName;
+    }
+
+    public void setResponseConnectionName(QName responseConnectionName) {
+        this.responseConnectionName = responseConnectionName;
+    }
+
+    public QName getResponseConnectionName() {
+        return responseConnectionName;
+    }
+
+    public void setRequestConnectionBinding(JMSBinding binding) {
+        this.requestConnectionBinding = binding;
+    }
+    public JMSBinding getRequestConnectionBinding() {
+        return requestConnectionBinding;
+    }
+
+    public void setResponseConnectionBinding(JMSBinding binding) {
+        this.responseConnectionBinding = binding;
+    }
+    public JMSBinding getResponseConnectionBinding() {
+        return responseConnectionBinding;
+    }
+    
+    public void setOperationPropertiesName(QName nameValue) {
+        this.operationPropertiesName = nameValue;
+    }
+    public QName getOperationPropertiesName() {
+        return operationPropertiesName;
+    }
+
+    public void setOperationPropertiesBinding(JMSBinding binding) {
+        this.operationPropertiesBinding = binding;
+    }
+    public JMSBinding getOperationPropertiesBinding() {
+        return operationPropertiesBinding;
+    }
+
+    // operations required by PolicySetAttachPoint
+    public List<PolicySet> getPolicySets() {
+        return policySets;
+    }
+    
+    public List<PolicySet> getApplicablePolicySets() {
+        return applicablePolicySets;
+    }     
+    
+    // operations required by IntentAttachPoint 
+    public List<Intent> getRequiredIntents() {
+        return requiredIntents;
+    } 
+
+    public QName getType() {
+        return TYPE;
+    }
+    
+    public Map<String, BindingProperty> getDestinationProperties() {
+        return destinationProperties;
+    }
+
+    public Map<String, BindingProperty> getConnectionFactoryProperties() {
+        return connectionFactoryProperties;
+    }
+
+    public Map<String, BindingProperty> getResourceAdapterProperties() {
+        return resourceAdapterProperties;
+    }
+
+    public Map<String, BindingProperty> getActivationSpecProperties() {
+        return activationSpecProperties;
+    }
+
+    public Map<String, BindingProperty> getResponseActivationSpecProperties() {
+        return responseActivationSpecProperties;
+    }
+
+    public Map<String, BindingProperty> getResponseDestinationProperties() {
+        return responseDestinationProperties;
+    }
+
+    public Map<String, BindingProperty> getResponseConnectionFactoryProperties() {
+        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);
+    }
+
+    public List<ConfiguredOperation> getConfiguredOperations() {
+        return configuredOperations;
+    }
+
+    public void setConfiguredOperations(List<ConfiguredOperation> configuredOperations) {
+        this.configuredOperations = configuredOperations;
+    }    
+    
+    public String getTargetNamespace() {
+        return targetNamespace;
+    }
+
+    public void setTargetNamespace(String ns) {
+        targetNamespace = ns;
+    }
+
+    // hashCode() is here because binding elements in definitions documents are added
+    // to the model resolver hashmap.  The namespace and name are keys.
+    @Override
+    public int hashCode() {
+        return (String.valueOf(getTargetNamespace()) + String.valueOf(getName())).hashCode();
+    }
+
+    @Override
+    public boolean equals( Object object ) {
+        return ( object instanceof JMSBinding ) && equals( (JMSBinding) object );
+    }
+
+    /**
+     * Compares two JMS bindings for equality.
+     * Because of the many fields, this comparison is rather large O(n).
+     * @param binding test binding for equality comparison 
+     * @return boolean stating whether objects are equal
+     */
+    public boolean equals( JMSBinding binding ) {
+        // If the target namespace is set, this binding came from a definitions document.
+        // The target namespace and name are used as keys for doing model resolver hashmap lookups.
+        // Only the target namespace and name can be compared.
+        if (this.targetNamespace != null) {
+            if ( !optStringEquals( this.targetNamespace, binding.getTargetNamespace() )) return false;
+            if ( !optStringEquals( this.name, binding.getName() )) return false;
+            return true;
+        }
+
+        // Test all fields for equality.
+        // First test simple fields to quickly weed out mismatches.
+        if ( !optStringEquals( this.uri, binding.getURI() )) return false;
+        if ( !optStringEquals( this.name, binding.getName() )) return false;
+        if ( !optStringEquals( this.targetNamespace, binding.getTargetNamespace() )) return false;
+        if ( !optStringEquals( this.destinationName, binding.getDestinationName() )) return false;
+        if ( !optStringEquals( this.correlationScheme, binding.getCorrelationScheme() )) return false;
+        if ( !optStringEquals( this.initialContextFactoryName, binding.getInitialContextFactoryName() )) return false;
+        if ( !optStringEquals( this.jndiURL, binding.getJndiURL() )) return false;
+        if ( !optStringEquals( this.requestConnectionName, binding.getRequestConnectionName() )) return false;
+        if ( !optStringEquals( this.responseConnectionName, binding.getResponseConnectionName() )) return false;
+        if ( !optStringEquals( this.jmsSelector, binding.getJMSSelector() )) return false;
+        if ( !equals( properties, binding.getProperties()) )
+            return false;
+
+        // Test operation properties
+        Set<String> operationNamesA = this.getOperationNames();
+        Set<String> operationNamesB = binding.getOperationNames();
+        if ( operationNamesA != null && operationNamesB != null ) {
+            if ( operationNamesA == null && operationNamesB != null ) return false;     
+            if ( operationNamesA != null && operationNamesB == null ) return false;     
+            if ( operationNamesA.size() != operationNamesB.size() ) return false;     
+            for(Iterator<String> it=operationNamesA.iterator(); it.hasNext(); ) {
+                String opName = it.next();
+                if ( !operationNamesB.contains( opName )) {
+                    return false;
+                }
+            }        
+        }
+
+        // Destination properties
+        if ( !optStringEquals( this.getDestinationName(), binding.getDestinationName() )) return false;
+        if ( !optStringEquals( this.getDestinationType(), binding.getDestinationType() )) return false;
+
+        // Connection factory properties
+        if ( !optStringEquals( this.getConnectionFactoryName(), binding.getConnectionFactoryName() )) return false;
+
+        // Activation spec properties
+        if ( !optStringEquals( this.getActivationSpecName(), binding.getActivationSpecName() )) return false;
+
+        // Response properties
+        if ( !optStringEquals( this.getResponseDestinationName(), binding.getResponseDestinationName() )) return false;
+        if ( !optStringEquals( this.getResponseActivationSpecName(), binding.getResponseActivationSpecName() )) return false;
+        if ( !optStringEquals( this.getResponseConnectionFactoryName(), binding.getResponseConnectionFactoryName() )) return false;
+
+        // Resource adapter
+        if ( !optStringEquals( this.getResourceAdapterName(), binding.getResourceAdapterName() )) return false;
+
+        // Configured operations
+        if ( this.configuredOperations.size() != binding.getConfiguredOperations().size() ) return false;
+        
+        // wire format
+        if ( this.getRequestWireFormat().getClass() != binding.getRequestWireFormat().getClass()) return false;
+        if ( this.getResponseWireFormat().getClass() != binding.getResponseWireFormat().getClass()) return false;
+        
+        // operation selector
+        if ( this.getOperationSelector().getClass() != binding.getOperationSelector().getClass()) return false;
+        
+        
+        // Other fields could also be checked for equality. See class fields for details.
+        return true;
+    }
+    
+    /**
+     * Tests if Strings are equal. 
+     * Either one may be null. This will match true if both
+     * are null or both are non-null and equal.
+     * @param p1 property list 1
+     * @param p2 property list 2
+     * @return whether or not properties are equal
+     */
+    public static boolean optStringEquals( Object s1, Object s2 ) {
+        if ( s1 == null && s2 == null ) return true;
+        if ( s1 != null && s2 == null ) return false;
+        if ( s1 == null && s2 != null ) return false;
+        return s1.equals( s2 );
+    }
+    
+    /**
+     * Tests if two property lists are equal.
+     * Either one may be null. This will match true if both
+     * are null or both are non-null and equal.
+     * @param p1 property list 1
+     * @param p2 property list 2
+     * @return whether or not properties are equal
+     */
+    public static boolean equals( Map<String, Object> p1, Map<String, Object> p2 ) {
+        if ( p1 == null && p2 == null)
+            return true;
+        if ( p1 == null || p2 == null)
+            return false;
+        if ( p1.size() != p2.size())
+            return false;
+
+        // For both the keys and values of a map
+        for (Iterator it=p1.entrySet().iterator(); it.hasNext(); ) {
+            Map.Entry entry = (Map.Entry)it.next();
+            Object k1 = entry.getKey();
+            Object v1 = entry.getValue();            
+            Object v2 = p2.get( k1 );
+            
+            if ( v1 == null && v2 != null )
+                return false;
+            if ( v1 != null && v2 == null )
+                return false;
+            if ( !v1.equals( v2 ))
+                return false;            
+        }
+        
+        return true;
+    }
+
+    public ExtensionType getExtensionType() {
+        return extensionType;
+    }
+
+    public void setExtensionType(ExtensionType intentAttachPointType) {
+        this.extensionType = intentAttachPointType;
+    }
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBindingConstants.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBindingConstants.java
new file mode 100644
index 0000000000..80bc61baa1
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBindingConstants.java
@@ -0,0 +1,75 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms;
+
+import java.util.Arrays;
+import java.util.List;
+
+import javax.xml.namespace.QName;
+
+import org.apache.tuscany.sca.assembly.xml.Constants;
+
+/**
+ * Constants for the JMS binding.
+ *
+ * @version $Rev$ $Date$
+ */
+public interface JMSBindingConstants {
+
+    // Constants used when describing the JMS binding
+    // model and for setting up defaults
+    String BINDING_JMS = "binding.jms";
+    QName BINDING_JMS_QNAME = new QName(Constants.SCA11_NS, BINDING_JMS);
+    String CORRELATE_MSG_ID = "requestmsgidtocorrelid";
+    String CORRELATE_CORRELATION_ID = "requestcorrelidtocorrelid";
+    String CORRELATE_NONE = "none";
+    List<String> VALID_CORRELATION_SCHEMES =
+        Arrays.asList(new String[] {CORRELATE_MSG_ID, CORRELATE_CORRELATION_ID, CORRELATE_NONE});
+    String DESTINATION_TYPE_QUEUE = "queue"; // 0
+    String DESTINATION_TYPE_TOPIC = "topic"; // 1
+    List<String> VALID_DESTINATION_TYPES =
+        Arrays.asList(new String[] {DESTINATION_TYPE_QUEUE, DESTINATION_TYPE_TOPIC});
+    String CREATE_ALWAYS = "always";
+    String CREATE_NEVER = "never";
+    String CREATE_IF_NOT_EXIST = "ifnotexist";
+    String DEFAULT_CONTEXT_FACTORY_NAME = "org.apache.activemq.jndi.ActiveMQInitialContextFactory";
+    String DEFAULT_JNDI_URL = "tcp://localhost:61616";
+    int DEFAULT_TIME_TO_LIVE = 20000; // in milliseconds
+    int DEFAULT_PRIORITY = 1;
+    int NON_PERSISTENT = 1; // Maps to javax.jms.DeliveryMode
+    String DEFAULT_RF_CLASSNAME = "org.apache.tuscany.sca.host.jms.activemq.JMSResourceFactoryImpl";
+    String XML_MP_CLASSNAME = "org.apache.tuscany.sca.binding.jms.provider.XMLTextMessageProcessor";
+    String TEXT_MP_CLASSNAME = "org.apache.tuscany.sca.binding.jms.provider.TextMessageProcessor";
+    String OBJECT_MP_CLASSNAME = "org.apache.tuscany.sca.binding.jms.provider.ObjectMessageProcessor";
+    String BYTES_MP_CLASSNAME = "org.apache.tuscany.sca.binding.jms.provider.BytesMessageProcessor";
+    String XML_BYTES_MP_CLASSNAME = "org.apache.tuscany.sca.binding.jms.provider.XMLBytesMessageProcessor";
+    String DEFAULT_MP_CLASSNAME = "org.apache.tuscany.sca.binding.jms.provider.DefaultMessageProcessor";
+    String DEFAULT_OPERATION_PROP_NAME = "scaOperationName";
+
+    String FAULT_PROPERTY = "org_apache_tuscany_sca_fault";
+    
+    String CALLBACK_ID_PROPERTY = "CallbackID";
+    String CALLBACK_Q_PROPERTY = "scaCallbackQueue";
+    String CONVERSATION_ID_PROPERTY = "scaConversationId";
+    
+    // XML element and attribute names
+    String HEADERS = "headers";
+    
+    int MSG_CTXT_POSITION = 0;
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBindingException.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBindingException.java
new file mode 100644
index 0000000000..74f030ca21
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBindingException.java
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms;
+
+/**
+ * Base exception for the JMSBinding.
+ *
+ * @version $Rev$ $Date$
+ */
+public class JMSBindingException extends RuntimeException {
+    private static final long serialVersionUID = 1L;
+
+    public JMSBindingException() {
+        super();
+    }
+
+    public JMSBindingException(String arg0, Throwable arg1) {
+        super(arg0, arg1);
+    }
+
+    public JMSBindingException(String arg0) {
+        super(arg0);
+    }
+
+    public JMSBindingException(Throwable arg0) {
+        super(arg0);
+    }
+
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBindingProcessor.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBindingProcessor.java
new file mode 100644
index 0000000000..be5673bc60
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBindingProcessor.java
@@ -0,0 +1,1541 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+
+package org.apache.tuscany.sca.binding.jms;
+
+import static javax.xml.stream.XMLStreamConstants.END_ELEMENT;
+import static javax.xml.stream.XMLStreamConstants.START_ELEMENT;
+
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.StringTokenizer;
+
+import javax.xml.namespace.QName;
+import javax.xml.stream.XMLStreamException;
+import javax.xml.stream.XMLStreamReader;
+import javax.xml.stream.XMLStreamWriter;
+
+import org.apache.tuscany.sca.assembly.ConfiguredOperation;
+import org.apache.tuscany.sca.assembly.OperationSelector;
+import org.apache.tuscany.sca.assembly.OperationsConfigurator;
+import org.apache.tuscany.sca.assembly.WireFormat;
+import org.apache.tuscany.sca.assembly.xml.ConfiguredOperationProcessor;
+import org.apache.tuscany.sca.assembly.xml.Constants;
+import org.apache.tuscany.sca.assembly.xml.PolicySubjectProcessor;
+import org.apache.tuscany.sca.binding.jms.operationselector.OperationSelectorJMSDefault;
+import org.apache.tuscany.sca.binding.jms.wireformat.WireFormatJMSDefault;
+import org.apache.tuscany.sca.binding.jms.wireformat.WireFormatJMSObject;
+import org.apache.tuscany.sca.binding.jms.wireformat.WireFormatJMSText;
+import org.apache.tuscany.sca.binding.jms.wireformat.WireFormatJMSTextXML;
+import org.apache.tuscany.sca.contribution.processor.BaseStAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.processor.ContributionReadException;
+import org.apache.tuscany.sca.contribution.processor.ContributionResolveException;
+import org.apache.tuscany.sca.contribution.processor.ContributionWriteException;
+import org.apache.tuscany.sca.contribution.processor.ProcessorContext;
+import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.resolver.ModelResolver;
+import org.apache.tuscany.sca.core.FactoryExtensionPoint;
+import org.apache.tuscany.sca.monitor.Monitor;
+import org.apache.tuscany.sca.monitor.Problem;
+import org.apache.tuscany.sca.monitor.Problem.Severity;
+import org.apache.tuscany.sca.policy.PolicyFactory;
+
+/**
+ * A processor to read the XML that describes the JMS binding...
+ * 
+ * <binding.jms correlationScheme="string"?
+ *              initialContextFactory="xs:anyURI"?
+ *              jndiURL="xs:anyURI"?
+ *              requestConnection="QName"?
+ *              responseConnection="QName"?
+ *              operationProperties="QName"?
+ *              ...>
+ * 
+ *     <headers type="string"?
+ *              deliveryMode="string"?
+ *              timeToLive="int"?
+ *              priority="string"?>
+ *         <property name="NMTOKEN" type="NMTOKEN">*
+ *     </headers>?
+ * 
+ *     <destination jndiName="xs:anyURI" type="string"? create="string"?>
+ *         <property name="NMTOKEN" type="NMTOKEN">*
+ *     </destination>?
+ * 
+ *     <connectionFactory jndiName="xs:anyURI" create="string"?>
+ *         <property name="NMTOKEN" type="NMTOKEN">*
+ *     </connectionFactory>?
+ * 
+ *     <activationSpec name="xs:anyURI" create="string"?>
+ *         <property name="NMTOKEN" type="NMTOKEN">*
+ *     </activationSpec>?
+ * 
+ *     <response>
+ *         <destination jndiName="xs:anyURI" type="string"? create="string"?>
+ *             <property name="NMTOKEN" type="NMTOKEN">*
+ *         </destination>?
+ * 
+ *         <connectionFactory jndiName="xs:anyURI" create="string"?>
+ *             <property name="NMTOKEN" type="NMTOKEN">*
+ *         </connectionFactory>?
+ * 
+ *         <activationSpec name="xs:anyURI" create="string"?>
+ *             <property name="NMTOKEN" type="NMTOKEN">*
+ *         </activationSpec>?
+ *         
+ *         <wireFormat.someWireFormat/>?
+ *     </response>?
+ * 
+ *     <complexType name="SubscriptionHeaders"> 
+ *         <attribute name="JMSSelector" type="string"/> 
+ *     </complexType>
+ *
+ *     <resourceAdapter name="NMTOKEN">?
+ *         <property name="NMTOKEN" type="NMTOKEN">*
+ *     </resourceAdapter>?
+ * 
+ *     <operationProperties name="string" nativeOperation="string"?>
+ *         <property name="NMTOKEN" type="NMTOKEN">*
+ *         <headers type="string"?
+ *                  deliveryMode="string"?
+ *                  timeToLive="int"?
+ *                  priority="string"?>
+ *             <property name="NMTOKEN" type="NMTOKEN">*
+ *         </headers>?
+ *     </operationProperties>*
+ *     
+ *     <wireFormat.someWireFormat/>?
+ * </binding.jms>
+ *
+ * Parsing error messages are recorded locally and reported as validation exceptions. Parsing
+ * warnings do not cause validation exceptions.
+ *
+ * @version $Rev$ $Date$
+ */
+
+public class JMSBindingProcessor extends BaseStAXArtifactProcessor implements StAXArtifactProcessor<JMSBinding> {
+    private PolicyFactory policyFactory;
+    private PolicySubjectProcessor policyProcessor;
+    private ConfiguredOperationProcessor configuredOperationProcessor;
+    protected StAXArtifactProcessor<Object> extensionProcessor;
+    
+
+    private FactoryExtensionPoint modelFactories; // DOB
+    public JMSBindingProcessor(FactoryExtensionPoint modelFactories, StAXArtifactProcessor<Object> extensionProcessor) {
+        this.policyFactory = modelFactories.getFactory(PolicyFactory.class);
+        this.policyProcessor = new PolicySubjectProcessor(policyFactory);
+
+        this.configuredOperationProcessor = 
+            new ConfiguredOperationProcessor(modelFactories);
+        this.extensionProcessor = extensionProcessor;
+        this.modelFactories = modelFactories;
+    }
+    
+    /**
+     * Report a error.
+     * 
+     * @param problems
+     * @param message
+     * @param model
+    */
+    private void warning(Monitor monitor, String message, Object model, Object... messageParameters) {
+        if (monitor != null) {
+            Problem problem = monitor.createProblem(this.getClass().getName(), "binding-jms-validation-messages", Severity.WARNING, model, message, (Object[])messageParameters);
+    	    monitor.problem(problem);
+        }        
+    }
+     
+    /**
+      * Report an error.
+      * One side effect is that error messages are saved for future validation calls.
+      * 
+      * @param problems
+      * @param message
+      * @param model
+    */
+    private void error(Monitor monitor, String message, Object model, Object... messageParameters) {
+        if (monitor != null) {
+            Problem problem = monitor.createProblem(this.getClass().getName(), "binding-jms-validation-messages", Severity.ERROR, model, message, (Object[])messageParameters);
+     	    monitor.problem(problem);
+        }        
+    }
+
+    public QName getArtifactType() {
+        return JMSBindingConstants.BINDING_JMS_QNAME;
+    }
+
+    public Class<JMSBinding> getModelType() {
+        return JMSBinding.class;
+    }
+
+    public JMSBinding read(XMLStreamReader reader, ProcessorContext context) throws ContributionReadException, XMLStreamException {
+        Monitor monitor = context.getMonitor();
+        JMSBinding jmsBinding = new JMSBinding();
+        // Reset validation message to keep track of validation issues.
+
+        // Read policies
+        policyProcessor.readPolicies(jmsBinding, reader);
+
+        // Read binding name
+        String name = reader.getAttributeValue(null, "name");
+        if (name != null) {
+            jmsBinding.setName(name);
+        }
+
+        // Read binding URI
+        String uri = reader.getAttributeValue(null, "uri");
+        if (uri != null && uri.length() > 0) {
+            parseURI(uri, jmsBinding, monitor);
+        }
+
+        // Read correlation scheme
+        String correlationScheme = reader.getAttributeValue(null, "correlationScheme");
+        if (correlationScheme != null && correlationScheme.length() > 0) {
+            if (JMSBindingConstants.VALID_CORRELATION_SCHEMES.contains(correlationScheme.toLowerCase())) {
+                jmsBinding.setCorrelationScheme(correlationScheme);
+            } else {
+            	error(monitor, "InvalidCorrelationScheme", reader, correlationScheme);
+            }
+        }
+
+        // Read initial context factory
+        String initialContextFactory = reader.getAttributeValue(null, "initialContextFactory");
+        if (initialContextFactory != null && initialContextFactory.length() > 0) {
+            jmsBinding.setInitialContextFactoryName(initialContextFactory);
+        }
+
+        // Read JNDI URL
+        String jndiURL = reader.getAttributeValue(null, "jndiURL");
+        if (jndiURL != null && jndiURL.length() > 0) {
+            jmsBinding.setJndiURL(jndiURL);
+        }
+
+        // Read message processor class name
+        // TODO - maintain this for the time being but move over to 
+        //        configuring wire formats instead of message processors
+        String messageProcessorName = reader.getAttributeValue(null, "messageProcessor");
+        if (messageProcessorName != null && messageProcessorName.length() > 0) {
+            if ("XMLTextMessage".equalsIgnoreCase(messageProcessorName)) {
+                // may be overwritten be real wire format later
+                jmsBinding.setRequestWireFormat(new WireFormatJMSTextXML());
+                jmsBinding.setResponseWireFormat(jmsBinding.getRequestWireFormat());
+            } else if ("TextMessage".equalsIgnoreCase(messageProcessorName)) {
+                // may be overwritten be real wire format later
+                jmsBinding.setRequestWireFormat(new WireFormatJMSText());
+                jmsBinding.setResponseWireFormat(jmsBinding.getRequestWireFormat());
+            } else if ("ObjectMessage".equalsIgnoreCase(messageProcessorName)) {
+                // may be overwritten be real wire format later
+                jmsBinding.setRequestWireFormat(new WireFormatJMSObject());
+                jmsBinding.setResponseWireFormat(jmsBinding.getRequestWireFormat());
+            } else {
+                jmsBinding.setRequestMessageProcessorName(messageProcessorName);
+                jmsBinding.setResponseMessageProcessorName(messageProcessorName);
+                // exploit the text wire format code to drive the user selected 
+                // message processor
+                jmsBinding.setRequestWireFormat(new WireFormatJMSText());
+                jmsBinding.setResponseWireFormat(jmsBinding.getRequestWireFormat());
+            }
+        }
+
+        String requestConnectionName = reader.getAttributeValue(null, "requestConnection");
+        if (requestConnectionName != null && requestConnectionName.length() > 0) {
+            jmsBinding.setRequestConnectionName(getQNameValue(reader, requestConnectionName));
+        }
+        String responseConnectionName = reader.getAttributeValue(null, "responseConnection");
+        if (responseConnectionName != null && responseConnectionName.length() > 0) {
+            jmsBinding.setResponseConnectionName(getQNameValue(reader, responseConnectionName));
+        }
+
+        String operationPropertiesName = reader.getAttributeValue(null, "operationProperties");
+        if (operationPropertiesName != null && operationPropertiesName.length() > 0) {
+            jmsBinding.setOperationPropertiesName(getQNameValue(reader, operationPropertiesName));
+        }
+
+        // Read sub-elements of binding.jms
+        boolean endFound = false;
+        while (!endFound) {
+            int fg = reader.next();
+            switch (fg) {
+                case START_ELEMENT:
+                    String elementName = reader.getName().getLocalPart();
+                    if ("destination".equals(elementName)) {
+                        parseDestination(reader, jmsBinding, monitor);
+                    } else if ("connectionFactory".equals(elementName)) {
+                        parseConnectionFactory(reader, jmsBinding, monitor);
+                    } else if ("activationSpec".equals(elementName)) {
+                        parseActivationSpec(reader, jmsBinding, monitor);
+                    } else if ("response".equals(elementName)) {
+                        parseResponse(reader, jmsBinding, context);
+                    } else if ("resourceAdapter".equals(elementName)) {
+                        parseResourceAdapter(reader, jmsBinding, monitor);
+                    } else if ("headers".equals(elementName)) {
+                        parseHeaders(reader, jmsBinding, monitor);
+                    } else if ("operationProperties".equals(elementName)) {
+                        parseOperationProperties(reader, jmsBinding, monitor);
+                    } else if ("messageSelection".equals(elementName)) {
+                        parseSubscriptionHeaders(reader, jmsBinding);
+                    } else if (Constants.OPERATION_QNAME.equals(reader.getName())) {
+                        ConfiguredOperation confOp = configuredOperationProcessor.read(reader, context);
+                        if (confOp != null) {
+                            ((OperationsConfigurator)jmsBinding).getConfiguredOperations().add(confOp);
+                        }
+                    } else {
+                        Object extension = extensionProcessor.read(reader, context);
+                        if (extension != null) {
+                            if (extension instanceof WireFormat) {
+                                if (jmsBinding.getRequestWireFormat() == null) {
+                                    jmsBinding.setRequestWireFormat((WireFormat) extension);
+                                } else {
+                                    throw new ContributionReadException("The request wireformat has already been defined. " + "Only one request wire format can be specified.");
+                                }
+                            } else if (extension instanceof OperationSelector) {
+                                if (jmsBinding.getOperationSelector() == null) {
+                                    jmsBinding.setOperationSelector((OperationSelector) extension);
+                                } else {
+                                    throw new ContributionReadException("More than one operation selector has been specified. " + "Only one operation selector can be specified.");
+                                }
+
+                            } else {
+                                error(monitor, "UnexpectedElement", reader, extension.toString());
+                            }
+                        }
+                    }
+                    //reader.next();
+                    break;
+                case END_ELEMENT:
+                    QName x = reader.getName();
+                    if (Constants.OPERATION.equals(x.getLocalPart())) break;
+                    // This assumption is not captured in schema, which isn't good, but will probably be fine for now.
+                    // A better solution might be to require each processor to advance to its own END_ELEMENT.
+                    if (x.getLocalPart().startsWith("wireFormat.") || x.getLocalPart().startsWith("operationSelector.")) {                         
+                        break;
+                    }
+                    if (x.equals(JMSBindingConstants.BINDING_JMS_QNAME)) {
+                        endFound = true;
+                    } else {
+                    	error(monitor, "UnexpectedElement: expected " + JMSBindingConstants.BINDING_JMS_QNAME + ", found " + x.toString(), 
+                    	      reader, x.toString());
+                    }
+            }
+        }
+        
+        // if no operation selector is specified then assume the default
+        if (jmsBinding.getOperationSelector() == null){
+            jmsBinding.setOperationSelector(new OperationSelectorJMSDefault());
+        }
+        
+        // if no request wire format specified then assume the default
+        if (jmsBinding.getRequestWireFormat() == null){
+            jmsBinding.setRequestWireFormat(new WireFormatJMSDefault());
+        }
+        
+        // if no response wire format specific then assume the same as the request
+        if (jmsBinding.getResponseWireFormat() == null){
+            jmsBinding.setResponseWireFormat(jmsBinding.getRequestWireFormat());
+         }
+
+        validate( jmsBinding, monitor );
+
+        return jmsBinding;
+    }
+
+    protected void parseURI(String uri, JMSBinding jmsBinding, Monitor monitor) {
+        if (!uri.startsWith("jms:")) {
+        	error(monitor, "MustStartWithSchema", jmsBinding, uri);
+        	return;
+        }
+        int i = uri.indexOf('?');            
+        if (i >= 0) {
+        	StringTokenizer st = new StringTokenizer(uri.substring(i+1),"&");
+        	while (st.hasMoreTokens()) {
+        	    String s = st.nextToken();
+        	    if (s.startsWith("connectionFactoryName=")) {
+        	        jmsBinding.setConnectionFactoryName(s.substring(22));
+        	    } else {
+        	        error(monitor, "UnknownTokenInURI", jmsBinding, s, uri);
+                 	return;
+        	     }
+        	}
+        	jmsBinding.setDestinationName(uri.substring(4, i));
+        } else {
+           jmsBinding.setDestinationName(uri.substring(4));
+        }
+    }
+
+    public void resolve(JMSBinding model, ModelResolver resolver, ProcessorContext context) throws ContributionResolveException {
+        Monitor monitor = context.getMonitor();
+        if (model.getRequestConnectionName() != null) {
+            model.setRequestConnectionBinding(getConnectionBinding(model, "requestConnection", model.getRequestConnectionName(), resolver, context));
+        }
+        if (model.getResponseConnectionName() != null) {
+            model.setResponseConnectionBinding(getConnectionBinding(model, "responseConnection", model.getResponseConnectionName(), resolver, context));
+        }
+        if (model.getOperationPropertiesName() != null) {
+            model.setOperationPropertiesBinding(getConnectionBinding(model, "operationProperties", model.getOperationPropertiesName(), resolver, context));
+        }
+    }
+
+    @SuppressWarnings("unchecked")
+    private JMSBinding getConnectionBinding(JMSBinding model, String attrName, QName bindingName, ModelResolver resolver, ProcessorContext context) {
+        JMSBinding binding = new JMSBinding();
+        binding.setTargetNamespace(bindingName.getNamespaceURI());
+        binding.setName(bindingName.getLocalPart());
+        binding.setUnresolved(true);
+        binding = resolver.resolveModel(JMSBinding.class, binding, context);
+        if (binding.isUnresolved())
+            error(context.getMonitor(), "BindingNotFound", model, attrName, bindingName);
+        return binding;
+    }
+
+    private void parseDestination(XMLStreamReader reader, JMSBinding jmsBinding, Monitor monitor) throws XMLStreamException {
+        String name = reader.getAttributeValue(null, "jndiName");
+        if (name != null && name.length() > 0) {
+            jmsBinding.setDestinationName(name);
+        }
+
+        String type = reader.getAttributeValue(null, "type");                
+        if (type != null && type.length() > 0) {
+            warning(monitor, "DoesntProcessDestinationType", jmsBinding);
+            if (JMSBindingConstants.DESTINATION_TYPE_QUEUE.equalsIgnoreCase(type)) {
+                jmsBinding.setDestinationType(JMSBindingConstants.DESTINATION_TYPE_QUEUE);
+            } else if (JMSBindingConstants.DESTINATION_TYPE_TOPIC.equalsIgnoreCase(type)) {
+                jmsBinding.setDestinationType(JMSBindingConstants.DESTINATION_TYPE_TOPIC);
+            } else {
+            	error(monitor, "InvalidDestinationType", reader, type);
+            }            
+        }
+
+        String create = reader.getAttributeValue(null, "create");
+        if (create != null && create.length() > 0) {
+            jmsBinding.setDestinationCreate(create);
+        }
+
+        jmsBinding.getDestinationProperties().putAll(parseBindingProperties(reader, monitor));
+    }
+
+    private void parseConnectionFactory(XMLStreamReader reader, JMSBinding jmsBinding, Monitor monitor) throws XMLStreamException {
+        String name = reader.getAttributeValue(null, "jndiName");
+        if (name != null && name.length() > 0) {
+            jmsBinding.setConnectionFactoryName(name);
+        } else {
+            error(monitor, "MissingConnectionFactoryName", reader);
+        }
+        jmsBinding.getConnectionFactoryProperties().putAll(parseBindingProperties(reader, monitor));
+    }
+
+    private void parseActivationSpec(XMLStreamReader reader, JMSBinding jmsBinding, Monitor monitor) throws XMLStreamException {
+        String name = reader.getAttributeValue(null, "name");        
+        if (name != null && name.length() > 0) {
+            jmsBinding.setActivationSpecName(name);            
+        } else {
+            warning(monitor, "MissingActivationSpecName", reader);
+        }
+        jmsBinding.getActivationSpecProperties().putAll(parseBindingProperties(reader, monitor));
+    }
+
+    private void parseResponseDestination(XMLStreamReader reader, JMSBinding jmsBinding, Monitor monitor) throws XMLStreamException {
+        String name = reader.getAttributeValue(null, "jndiName");
+        if (name != null && name.length() > 0) {
+            jmsBinding.setResponseDestinationName(name);
+        }
+
+        String type = reader.getAttributeValue(null, "type");        
+        if (type != null && type.length() > 0) {
+            warning(monitor, "DoesntProcessResponseDestinationType", jmsBinding);
+            if (JMSBindingConstants.DESTINATION_TYPE_QUEUE.equalsIgnoreCase(type)) {
+                jmsBinding.setResponseDestinationType(JMSBindingConstants.DESTINATION_TYPE_QUEUE);
+            } else if (JMSBindingConstants.DESTINATION_TYPE_TOPIC.equalsIgnoreCase(type)) {
+                jmsBinding.setResponseDestinationType(JMSBindingConstants.DESTINATION_TYPE_TOPIC);
+            } else {
+                error(monitor, "InvalidResponseDestinationType", reader, type);
+            }
+        }
+
+        String create = reader.getAttributeValue(null, "create");
+        if (create != null && create.length() > 0) {
+            jmsBinding.setResponseDestinationCreate(create);
+        }
+
+        jmsBinding.getResponseDestinationProperties().putAll(parseBindingProperties(reader, monitor));
+    }
+
+    private void parseResponseConnectionFactory(XMLStreamReader reader, JMSBinding jmsBinding, Monitor monitor) throws XMLStreamException {
+        String name = reader.getAttributeValue(null, "jndiName");
+        if (name != null && name.length() > 0) {
+            jmsBinding.setResponseConnectionFactoryName(name);            
+        } else {
+            warning(monitor, "MissingResponseConnectionFactory", reader);
+        }
+        jmsBinding.getResponseConnectionFactoryProperties().putAll(parseBindingProperties(reader, monitor));
+    }
+
+    private void parseResponseActivationSpec(XMLStreamReader reader, JMSBinding jmsBinding, Monitor monitor) throws XMLStreamException {
+        String name = reader.getAttributeValue(null, "name");
+        if (name != null && name.length() > 0) {
+            jmsBinding.setResponseActivationSpecName(name);            
+        } else {
+            warning(monitor, "MissingResponseActivationSpec", reader);
+        }
+        jmsBinding.getResponseActivationSpecProperties().putAll(parseBindingProperties(reader, monitor));
+    }
+
+    private void parseResponse(XMLStreamReader reader, JMSBinding jmsBinding, ProcessorContext context) throws ContributionReadException, XMLStreamException {
+        // Read sub-elements of response
+        Monitor monitor = context.getMonitor();
+        while (true) {
+            switch (reader.next()) {
+                case START_ELEMENT:
+                    String elementName = reader.getName().getLocalPart();
+                    if ("destination".equals(elementName)) {
+                        parseResponseDestination(reader, jmsBinding, context.getMonitor());
+                    } else if ("connectionFactory".equals(elementName)) {
+                        parseResponseConnectionFactory(reader, jmsBinding, monitor);
+                    } else if ("activationSpec".equals(elementName)) {
+                        parseResponseActivationSpec(reader, jmsBinding, monitor);
+                    } else {
+                        Object extension = extensionProcessor.read(reader, context);
+                        if (extension != null) {
+                            if (extension instanceof WireFormat) {
+                                if (jmsBinding.getResponseWireFormat() == null) {
+                                    jmsBinding.setResponseWireFormat((WireFormat)extension);
+                                } else {
+                                    throw new ContributionReadException("The response wireformat has already been defined. " + "Only one response wire format can be specified.");
+                                }
+                            } else {
+                                error(context.getMonitor(), "UnexpectedElement", reader, extension.toString());
+                            }
+                        }
+                        reader.next();
+                    }
+                    //reader.next();
+                    break;
+                case END_ELEMENT:
+                    QName x = reader.getName();
+                    if (x.getLocalPart().equals("response")) {
+                        return;
+                    } else {
+                    	error(context.getMonitor(), "UnexpectedResponseElement", reader, x.toString());
+                    }
+            }
+        }
+    }
+
+    private void parseResourceAdapter(XMLStreamReader reader, JMSBinding jmsBinding, Monitor monitor) throws XMLStreamException {
+        String name = reader.getAttributeValue(null, "name");        
+        if (name != null && name.length() > 0) {
+            jmsBinding.setResourceAdapterName(name);            
+        } else {
+            error(monitor, "MissingResourceAdapterName", reader);
+        }
+        jmsBinding.getResourceAdapterProperties().putAll(parseBindingProperties(reader, monitor));
+    }
+
+    /**
+     * <headers JMSType=”string”?
+     *          JMSCorrelationID=”string”?
+     *          JMSDeliveryMode=”PERSISTENT or NON_PERSISTENT”?
+     *          timeToLive=”long”?      
+     *          JMSPriority=”0 .. 9”?>
+     *     <property name=”NMTOKEN” type=”NMTOKEN”?>*    
+     * </headers>?
+     */
+    private void parseHeaders(XMLStreamReader reader, JMSBinding jmsBinding, Monitor monitor) throws XMLStreamException {
+        String jmsType = reader.getAttributeValue(null, "type");
+        if (jmsType != null && jmsType.length() > 0) {
+            jmsBinding.setJMSType(jmsType);
+        }
+
+        String jmsDeliveryMode = reader.getAttributeValue(null, "deliveryMode");
+        if (jmsDeliveryMode != null && jmsDeliveryMode.length() > 0) {
+            if ("persistent".equalsIgnoreCase(jmsDeliveryMode)) {
+                jmsBinding.setJMSDeliveryMode(true);
+            } else if ("nonpersistent".equalsIgnoreCase(jmsDeliveryMode)) {
+                jmsBinding.setJMSDeliveryMode(false);
+            } else {
+                error(monitor, "InvalidJMSDeliveryMode", jmsBinding, jmsDeliveryMode);
+            }
+        }
+
+        String jmsTimeToLive = reader.getAttributeValue(null, "timeToLive");
+        if (jmsTimeToLive != null && jmsTimeToLive.length() > 0) {
+            jmsBinding.setJMSTimeToLive(Long.parseLong(jmsTimeToLive));
+        }
+
+        String jmsPriority = reader.getAttributeValue(null, "priority");
+        if (jmsPriority != null && jmsPriority.length() > 0) {
+            try {
+                int p = Integer.parseInt(jmsPriority);
+                if (p >= 0 && p <= 9) {
+                    jmsBinding.setJMSPriority(p);
+                } else {
+                    warning(monitor, "InvalidJMSPriority", jmsBinding, jmsPriority);
+                }
+            } catch (NumberFormatException ex) {
+                error(monitor, "InvalidJMSPriority", jmsBinding, jmsPriority);
+            }
+        }
+
+        while (true) {
+            switch (reader.next()) {
+                case START_ELEMENT:
+                    if (reader.getName().getLocalPart().equals("property")) {
+                        parseProperty(reader, jmsBinding);
+                    }
+                    break;
+                case END_ELEMENT:
+                    QName x = reader.getName();
+                    if (x.getLocalPart().equals("headers")) {
+                        return;
+                    } else {
+                        error(monitor, "UnexpectedResponseElement", reader, x.toString());
+                    }
+            }
+        }
+    }
+    
+    private void parseProperty(XMLStreamReader reader, JMSBinding jmsBinding) throws XMLStreamException {
+        jmsBinding.setHeaders( true );
+        String name = reader.getAttributeValue(null, "name");
+        String type = reader.getAttributeValue(null, "type");        
+        if (name != null && name.length() > 0) {
+            Object value = reader.getElementText();
+            if ("boolean".equalsIgnoreCase(type)) {
+                value = Boolean.parseBoolean((String)value);
+            } else if ("byte".equalsIgnoreCase(type)) {
+                value = Byte.parseByte(((String)value));
+            } else if ("short".equalsIgnoreCase(type)) {
+                value = Short.parseShort((String)value);
+            } else if ("int".equalsIgnoreCase(type)) {
+                value = Integer.parseInt((String)value);
+            } else if ("long".equalsIgnoreCase(type)) {
+                value = Long.parseLong((String)value);
+            } else if ("float".equalsIgnoreCase(type)) {
+                value = Float.parseFloat((String)value);
+            } else if ("double".equalsIgnoreCase(type)) {
+                value = Double.parseDouble((String)value);
+            } else if ("String".equalsIgnoreCase(type)) {
+                // its already a string
+            }
+            jmsBinding.setProperty(name, value);
+        }
+    }
+
+    /**
+     * <operationProperties name=”string” nativeOperation=”string”?>
+     *   <property name=”NMTOKEN” type=”NMTOKEN”?>*
+     *   <headers JMSType=”string”?
+     *            JMSCorrelationID=”string”?
+     *            JMSDeliveryMode=”PERSISTENT or NON_PERSISTENT”?
+     *            timeToLive=”long”?
+     *            JMSPriority=”0 .. 9”?>
+     *       <property name=”NMTOKEN” type=”NMTOKEN”?>*
+     *   </headers>?
+     * </operationProperties>*
+     */
+    private void parseOperationProperties(XMLStreamReader reader, JMSBinding jmsBinding, Monitor monitor) throws XMLStreamException {
+        
+        if (jmsBinding.getOperationPropertiesName() != null) {
+            error(monitor, "DuplicateOperationProperties", jmsBinding);
+        }
+        
+        String opName = reader.getAttributeValue(null, "name");
+        if (opName == null || opName.length() < 1) {
+            warning(monitor, "MissingJMSOperationPropertyName", jmsBinding);
+            return;
+        }
+        // Since nativeOpName, headers, and property elements are optional, must add opName.
+        jmsBinding.addOperationName(opName);
+        String nativeOpName = reader.getAttributeValue(null, "nativeOperation"); // optional
+        if (nativeOpName != null && nativeOpName.length() > 0) {
+            jmsBinding.setNativeOperationName(opName, nativeOpName);
+        }
+
+        Map<String, BindingProperty> props = new HashMap<String, BindingProperty>();
+        while (true) {
+            switch (reader.next()) {
+                case START_ELEMENT:
+                    if (reader.getName().getLocalPart().equals("headers")) { // optional
+                        parseOperationHeaders(reader, jmsBinding, opName, monitor);
+                    } else if (reader.getName().getLocalPart().equals("property")) { // optional
+                    	processProperty(reader, props, monitor);
+                    }
+                break;
+                case END_ELEMENT:
+                    if (reader.isEndElement()) {
+                        QName x = reader.getName();
+                        if (x.getLocalPart().equals("headers")) {
+                            break;
+                        }
+                        if (x.getLocalPart().equals("property")) {
+                            break;
+                        }
+                        if (x.getLocalPart().equals("operationProperties")) {
+                        	jmsBinding.getOperationPropertiesProperties(opName).putAll(props);
+                            return;
+                        } else {
+                            error(monitor, "UnexpectedResponseElement", reader, x.toString());
+                        }
+                    }
+            }
+        }
+    }
+
+    private void parseOperationHeaders(XMLStreamReader reader, JMSBinding jmsBinding, String opName, Monitor monitor) throws XMLStreamException {
+        String jmsType = reader.getAttributeValue(null, "type");
+        if (jmsType != null && jmsType.length() > 0) {
+            jmsBinding.setOperationJMSType(opName, jmsType);
+        }
+
+        String jmsDeliveryMode = reader.getAttributeValue(null, "deliveryMode");
+        if (jmsDeliveryMode != null && jmsDeliveryMode.length() > 0) {
+            if ("persistent".equalsIgnoreCase(jmsDeliveryMode)) {
+                jmsBinding.setOperationJMSDeliveryMode(opName, true);
+            } else if ("nonpersistent".equalsIgnoreCase(jmsDeliveryMode)) {
+                jmsBinding.setOperationJMSDeliveryMode(opName, false);
+            } else {
+                error(monitor, "InvalidOPJMSDeliveryMode", jmsBinding, jmsDeliveryMode);
+            }
+        }
+
+        String jmsTimeToLive = reader.getAttributeValue(null, "timeToLive");
+        if (jmsTimeToLive != null && jmsTimeToLive.length() > 0) {
+            jmsBinding.setOperationJMSTimeToLive(opName, Long.parseLong(jmsTimeToLive));
+        }
+
+        String jmsPriority = reader.getAttributeValue(null, "priority");
+        if (jmsPriority != null && jmsPriority.length() > 0) {
+            try {
+                int p = Integer.parseInt(jmsPriority);
+                if (p >= 0 && p <= 9) {
+                    jmsBinding.setOperationJMSPriority(opName, p);
+                } else {
+                    warning(monitor, "InvalidOPJMSPriority", jmsBinding, jmsPriority);
+                }
+            } catch (NumberFormatException ex) {
+                error(monitor, "InvalidOPJMSPriority", jmsBinding, jmsPriority);
+            }
+        }
+
+        while (true) {
+            switch (reader.next()) {
+                case START_ELEMENT:
+                    if (reader.getName().getLocalPart().equals("property")) {
+                        parseOperationPropertyProperties(reader, jmsBinding, opName);
+                    }
+                    break;
+                case END_ELEMENT:
+                    QName x = reader.getName();
+                    if (x.getLocalPart().equals("headers")) {
+                        return;
+                    } else {
+                        error(monitor, "UnexpectedResponseElement", reader, x.toString());
+                    }
+            }
+        }
+    }
+
+    private void parseOperationPropertyProperties(XMLStreamReader reader, JMSBinding jmsBinding, String opName) throws XMLStreamException {
+        String propName = reader.getAttributeValue(null, "name");
+        String type = reader.getAttributeValue(null, "type");
+        if (propName != null && propName.length() > 0) {
+            Object value = reader.getElementText();
+            if ("boolean".equalsIgnoreCase(type)) {
+                value = Boolean.parseBoolean((String)value);
+            } else if ("byte".equalsIgnoreCase(type)) {
+                value = Byte.parseByte(((String)value));
+            } else if ("short".equalsIgnoreCase(type)) {
+                value = Short.parseShort((String)value);
+            } else if ("int".equalsIgnoreCase(type)) {
+                value = Integer.parseInt((String)value);
+            } else if ("long".equalsIgnoreCase(type)) {
+                value = Long.parseLong((String)value);
+            } else if ("float".equalsIgnoreCase(type)) {
+                value = Float.parseFloat((String)value);
+            } else if ("double".equalsIgnoreCase(type)) {
+                value = Double.parseDouble((String)value);
+            } else if ("String".equalsIgnoreCase(type)) {
+                // its already a string
+            }
+            jmsBinding.setOperationProperty(opName, propName, value);
+        }
+    }
+
+    private void parseSubscriptionHeaders(XMLStreamReader reader, JMSBinding jmsBinding) throws XMLStreamException {
+        String jmsSelector = reader.getAttributeValue(null, "selector");
+        if (jmsSelector != null && jmsSelector.length() > 0) {
+            jmsBinding.setJMSSelector(jmsSelector);
+        }
+        
+        // Skip to end element
+        while (reader.hasNext()) {
+            if (reader.next() == END_ELEMENT && "messageSelection".equals(reader.getName().getLocalPart())) {
+                break;
+            }
+        } // end while
+    }
+
+    private Map<String, BindingProperty> parseBindingProperties(XMLStreamReader reader, Monitor monitor) throws XMLStreamException {
+    	Map<String, BindingProperty> props = new HashMap<String, BindingProperty>();
+    	String parentName = reader.getName().getLocalPart();        
+        // Parse for all the properties within this element, until the end of
+        // the element is reached.
+    	boolean completed = false;
+        while (!completed) {
+            switch (reader.next()) {
+                case START_ELEMENT:
+                    String elementName = reader.getName().getLocalPart();
+                    if ("property".equals(elementName)) {
+                    	processProperty(reader, props, monitor);
+                    }
+                    break;
+                case END_ELEMENT:
+                	String endName = reader.getName().getLocalPart();
+                	if (parentName.equals(endName)) {
+                		completed = true;
+                        break;
+                	}
+            }
+        }        
+        return props;
+    }
+
+    private void processProperty(XMLStreamReader reader, Map<String, BindingProperty> props, Monitor monitor) throws XMLStreamException {
+        String name = reader.getAttributeValue(null, "name");
+        if (name == null || name.length() < 1) {
+            error(monitor, "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.
+     * However read(XMLStreamReader) now calls validate(JMSBinding jmsBinding) and
+     * passes in the jmsBinding model.
+     * The older validate() now calls validate(JMSBinding jmsBinding) with a null model. 
+     */
+    public void validate() {
+        validate( null, null );
+    }
+    
+    /**
+     * Validates JMS parsing and JMSBinding model.
+     * Validation rules are taken from the binding schema and the OSOA and OASIS specs:
+     *    http://www.oasis-open.org/committees/documents.php?wg_abbrev=sca-bindings
+     *    (sca-binding-jms-1.1-spec-cd01-rev4.pdf)
+     *    http://www.osoa.org/display/Main/Service+Component+Architecture+Specifications
+     *    (SCA JMS Binding V1.00 )
+     * @param jmsBinding an optional JMS binding model to check for validity.  
+     * @since 1.4
+     */
+    protected void validate( JMSBinding jmsBinding, Monitor monitor ) {        
+        // If no JMSBinding model is provided, that is all the validation we can do.
+        if ( jmsBinding == null ) {
+            return;
+        }
+
+        // Connection factory should not contradict destination type.
+        String connectionFactoryName = jmsBinding.getConnectionFactoryName();
+        if (( connectionFactoryName != null ) && ( connectionFactoryName.length() > 0 )) {
+            if (JMSBindingConstants.DESTINATION_TYPE_QUEUE == jmsBinding.getDestinationType()) {
+                if ( connectionFactoryName.contains( "topic" )) {
+                    error(monitor, "DestinationQueueContradiction", jmsBinding, connectionFactoryName );
+                }
+            }
+            if (JMSBindingConstants.DESTINATION_TYPE_TOPIC == jmsBinding.getDestinationType()) {
+                if ( connectionFactoryName.contains( "queue" )) {
+                    error(monitor, "DestinationTopicContradiction", jmsBinding, connectionFactoryName );
+                }
+            }
+        }
+        
+        // Connection factory and activation Specification are mutually exclusive.
+        if (( connectionFactoryName != null ) && ( connectionFactoryName.length() > 0 )) {
+            String activationSpecName = jmsBinding.getActivationSpecName();
+            if ((activationSpecName != null) && (activationSpecName.length() > 0 )) {
+                error(monitor, "ConnectionFactoryActivationSpecContradiction", jmsBinding, connectionFactoryName, activationSpecName );                
+            }
+        }
+
+        // Given a response connection name attribute, there must not be a response element.
+        // 156 • /binding.jms/@responseConnection – identifies a binding.jms element that is present in a
+        // 157 definition document, whose response child element is used to define the values for this binding. In
+        // 158 this case this binding.jms element MUST NOT contain a response element.
+        QName responseConnectionName = jmsBinding.getResponseConnectionName();
+        if (( responseConnectionName != null ) && ( responseConnectionName.getLocalPart().length() > 0 )) {
+            String responseDestinationName = jmsBinding.getResponseDestinationName();
+            if (( responseDestinationName != null ) && (responseDestinationName.length() > 0)) {
+                error(monitor, "ResponseAttrElement", jmsBinding, responseConnectionName, responseDestinationName );                               
+            }
+        }
+
+        // Other jmsBinding model validation may be added here.
+
+    }
+
+    /**
+     * Given a valid JMSBinding, write it as XML using the given XML writer.
+     * 
+     * This high-level method handles binding.jms element and its attributes. 
+     * Sub elements have their own writer methods and are called from here.
+     * <binding.jms 
+     *    correlationScheme="string"?
+     *    initialContextFactory="xs:anyURI"? 
+     *    jndiURL="xs:anyURI"?
+     *    requestConnection="QName"? 
+     *    responseConnection="QName"?
+     *    operationProperties="QName"? 
+     *    ...>
+     * @param writer an XMLStreamWriter that writes XML attributes and elements
+     * @param jmsBinding JMSBinding model
+     */
+    public void write(JMSBinding jmsBinding, XMLStreamWriter writer, ProcessorContext context) throws ContributionWriteException,
+        XMLStreamException {
+        // Write a <binding.jms>
+        writeStart(writer, Constants.SCA11_NS, JMSBindingConstants.BINDING_JMS,
+                   new XAttr("requestConnection", jmsBinding.getRequestConnectionName()),
+                   new XAttr("responseConnection", jmsBinding.getResponseConnectionName()),
+                   new XAttr("operationProperties", jmsBinding.getOperationPropertiesName()));
+
+        if (jmsBinding.getName() != null) {
+            writer.writeAttribute("name", jmsBinding.getName());
+        }
+
+        if (jmsBinding.getURI() != null) {
+            writer.writeAttribute("uri", jmsBinding.getURI());
+        }
+
+        //String dest = jmsBinding.getDestinationName();
+        //if (dest != null) {
+        //    if ( dest != null ) {
+        //       writer.writeAttribute("uri", "jms:" + jmsBinding.getDestinationName());
+        //    }
+        //}
+
+        String correlationScheme = jmsBinding.getCorrelationScheme();
+        if ( correlationScheme != null ) {
+            if ( !correlationScheme.equals(JMSBindingConstants.CORRELATE_MSG_ID) ) {
+               writer.writeAttribute("correlationScheme", jmsBinding.getCorrelationScheme());
+            }
+        }
+        
+        if ( jmsBinding.getInitialContextFactoryName() != null ) {
+            writer.writeAttribute("initialContextFactory", jmsBinding.getInitialContextFactoryName());            
+        }
+        
+        if ( jmsBinding.getJndiURL() != null ) {
+            writer.writeAttribute("jndiURL", jmsBinding.getJndiURL());            
+        }
+        
+        if ( jmsBinding.containsHeaders() ) {
+           writeHeaders( jmsBinding, writer);
+        }
+
+        writeOperationProperties( jmsBinding, writer );
+
+        writeSubscriptionHeaders( jmsBinding, writer );
+        
+        writeDestinationProperties( jmsBinding, writer );
+        
+        writeConnectionFactoryProperties( jmsBinding, writer );
+        
+        writeActivationSpecProperties( jmsBinding, writer );
+
+        // Write response info, if names are not defaults.
+        String responseDestName = jmsBinding.getResponseDestinationName();
+        String responseCFName = jmsBinding.getResponseConnectionFactoryName();
+        String responseASName = jmsBinding.getResponseActivationSpecName();
+        if (  responseDestName != null  || 
+              responseCFName != null  ||
+              responseASName != null ) {
+            
+           writer.writeStartElement(Constants.SCA11_NS, "response");
+           writeResponseDestinationProperties( jmsBinding, writer );       
+           writeResponseConnectionFactoryProperties( jmsBinding, writer );        
+           writeResponseActivationSpecProperties( jmsBinding, writer );
+           
+           if ((jmsBinding.getResponseWireFormat() != null) &&
+               !(jmsBinding.getResponseWireFormat() instanceof WireFormatJMSDefault)){
+               writeWireFormat(jmsBinding.getResponseWireFormat(), writer, context);
+           }
+           
+           writer.writeEndElement();
+           // Strange bug. Without white space, headers end tag improperly read. 
+           writer.writeCharacters( " " ); 
+        }
+        
+        writeResourceAdapterProperties( jmsBinding, writer );
+        
+        writeConfiguredOperations( jmsBinding, writer, context );
+        
+        if ((jmsBinding.getRequestWireFormat() != null) &&
+            !(jmsBinding.getRequestWireFormat() instanceof WireFormatJMSDefault)){
+            writeWireFormat(jmsBinding.getRequestWireFormat(), writer, context);
+        }
+        
+        if ((jmsBinding.getOperationSelector() != null) &&
+            !(jmsBinding.getOperationSelector() instanceof OperationSelectorJMSDefault)){
+            writeOperationSelector(jmsBinding.getOperationSelector(), writer, context);
+        }
+        
+        writeEnd(writer);
+    }
+
+    /**
+     * Writes headers element and its attributes.
+     * <headers JMSType=”string”?
+     *          JMSCorrelationID=”string”?
+     *          JMSDeliveryMode=”PERSISTENT or NON_PERSISTENT”?
+     *          timeToLive=”long”?      
+     *          JMSPriority=”0 .. 9”?>
+     *     <property name=”NMTOKEN” type=”NMTOKEN”?>*    
+     * </headers>?
+     */
+    private void writeHeaders( JMSBinding jmsBinding, XMLStreamWriter writer) throws XMLStreamException {
+
+        writer.writeStartElement(Constants.SCA11_NS, JMSBindingConstants.HEADERS);
+
+        String jmsType = jmsBinding.getJMSType();
+        if (jmsType != null && jmsType.length() > 0) {
+            writer.writeAttribute("type", jmsType);
+        }
+
+        Boolean jmsDeliveryMode = jmsBinding.isdeliveryModePersistent();
+        if (jmsDeliveryMode != null) {
+            if ( jmsDeliveryMode.booleanValue() )
+               writer.writeAttribute("deliveryMode", "persistent");
+            else
+               writer.writeAttribute("deliveryMode", "nonpersistent");
+        }
+
+        Long jmsTimeToLive = jmsBinding.getJMSTimeToLive();
+        if (jmsTimeToLive != null) {
+            writer.writeAttribute("timeToLive", jmsTimeToLive.toString());
+        }
+
+        Integer jmsPriority = jmsBinding.getJMSPriority();
+        if (jmsPriority != null) {
+            writer.writeAttribute("priority", jmsPriority.toString());
+        }
+
+        Map<String, Object> properties = jmsBinding.getProperties();
+        writeProperties( properties, writer );
+        //writer.writeCharacters( "   " );
+        
+        writer.writeEndElement();
+        // Strange bug. Without white space, headers end tag improperly read. 
+        writer.writeCharacters( " " ); 
+    }
+    
+    /**
+     * Writes a complete set of properties to the given XML stream writer.
+     * If the value is of type string, the property will be output:
+     *    <property name="key">StringValue</property>
+     * If the value is of type box (e.g.Integer, Long) or BindingProperty, the output will be    
+     *    <property name="key" type="int">42</property>
+     */
+    private void writeProperties(Map<String, Object> properties, XMLStreamWriter writer) throws XMLStreamException {
+        if (( properties == null ) || ( properties.size() == 0 )) {
+            return;
+        }
+        
+        // For both the keys and values of a map
+        for (Iterator it=properties.entrySet().iterator(); it.hasNext(); ) {
+            Map.Entry entry = (Map.Entry)it.next();
+            Object key = entry.getKey();
+            Object value = entry.getValue();
+
+            writer.writeStartElement(Constants.SCA11_NS, "property" );
+            writer.writeAttribute("name", key.toString());
+
+            if ( value instanceof String) {
+                writer.writeCharacters( value.toString() );
+            } else if ( value instanceof BindingProperty ) {
+                BindingProperty property = (BindingProperty) value;
+                String type = property.getType();
+                if ( type != null ) {
+                   writer.writeAttribute("type", type);
+                }
+                writer.writeCharacters( property.getValue().toString() );               
+            } else if ( value instanceof Boolean ) {
+                writer.writeAttribute("type", "boolean");
+                writer.writeCharacters( value.toString() );
+            } else if ( value instanceof Byte ) {
+                writer.writeAttribute("type", "byte");
+                writer.writeCharacters( value.toString() );
+            } else if ( value instanceof Short ) {
+                writer.writeAttribute("type", "short");
+                writer.writeCharacters( value.toString() );
+            } else if ( value instanceof Integer ) {
+                writer.writeAttribute("type", "int");
+                writer.writeCharacters( value.toString() );
+            } else if ( value instanceof Long ) {
+                writer.writeAttribute("type", "long");
+                writer.writeCharacters( value.toString() );
+            } else if ( value instanceof Float ) {
+                writer.writeAttribute("type", "float");
+                writer.writeCharacters( value.toString() );
+            } else if ( value instanceof Double ) {
+                writer.writeAttribute("type", "double");
+                writer.writeCharacters( value.toString() );
+            } else {
+                writer.writeCharacters( value.toString() );                
+            }
+            writer.writeEndElement();
+        }
+    }
+
+    /**
+     * Writes operation properties if there are any.
+     * 
+     *     <operationProperties name="string" nativeOperation="string"?>
+     *         <property name="NMTOKEN" type="NMTOKEN">*
+     *         <headers JMSType="string"?
+     *                  JMSCorrelationID="string"?
+     *                  JMSDeliveryMode="string"?
+     *                  timeToLive="int"?
+     *                  JMSPriority="string"?>
+     *             <property name="NMTOKEN" type="NMTOKEN">*
+     *         </headers>?
+     *     </operationProperties>*
+     * </binding.jms>
+     */
+    private void writeOperationProperties( JMSBinding jmsBinding, XMLStreamWriter writer) throws XMLStreamException {
+        if (jmsBinding.getOperationPropertiesBinding() != null) {
+            return;   
+        }
+        Set<String> operationNames = jmsBinding.getOperationNames();
+        if (operationNames == null || (operationNames.size() < 1)) {
+            return;
+        }
+
+        for(Iterator<String> it=operationNames.iterator(); it.hasNext(); ) {
+            String opName = it.next();
+        
+            writer.writeStartElement(Constants.SCA11_NS, "operationProperties");
+            writer.writeAttribute("name", opName);
+
+            String nativeOperation = jmsBinding.getNativeOperationName(opName);
+            if (nativeOperation != null && nativeOperation.length() > 0) {
+                if ( !nativeOperation.equals( opName )) {
+                   writer.writeAttribute("nativeOperation", nativeOperation);
+                }
+            }
+
+            Map<String, BindingProperty> operationPropertiesProperties =
+                jmsBinding.getOperationPropertiesProperties(opName);
+            writeBindingProperties( operationPropertiesProperties, writer );            
+
+            String jmsType = jmsBinding.getOperationJMSType(opName);
+            String jmsCorrelationId = jmsBinding.getOperationJMSCorrelationId(opName);
+            Boolean jmsDeliveryMode = jmsBinding.getOperationJMSDeliveryMode(opName);
+            Long jmsTimeToLive = jmsBinding.getOperationJMSTimeToLive(opName);
+            Integer jmsPriority = jmsBinding.getOperationJMSPriority(opName);
+            Map<String, Object> operationProperties = jmsBinding.getOperationProperties(opName);
+            
+            if (operationProperties != null){
+                if ((jmsType != null && jmsType.length() > 0) || 
+                    (jmsCorrelationId != null && jmsCorrelationId.length() > 0) || 
+                    jmsDeliveryMode != null || jmsTimeToLive != null || 
+                    jmsPriority != null) {
+                    
+                    writer.writeStartElement(Constants.SCA11_NS, JMSBindingConstants.HEADERS);              
+                    
+                    if (jmsType != null && jmsType.length() > 0) {
+                        writer.writeAttribute("type", jmsType);
+                    }
+    
+                    if (jmsDeliveryMode != null) {
+                        if (jmsDeliveryMode.booleanValue())
+                            writer.writeAttribute("deliveryMode", "persistent");
+                        else
+                            writer.writeAttribute("deliveryMode", "nonpersistent");
+                    }
+    
+                    if (jmsTimeToLive != null) {
+                        writer.writeAttribute("timeToLive", jmsTimeToLive.toString());
+                    }
+    
+                    if (jmsPriority != null) {
+                        writer.writeAttribute("priority", jmsPriority.toString());
+                    }
+                    
+                    writeProperties( operationProperties, writer );
+                    
+                    writer.writeEndElement();
+                    // Strange bug. Without white space, headers end tag improperly read. 
+                    // writer.writeCharacters( " " ); 
+                }
+            }
+
+            writer.writeEndElement();
+            // Strange bug. Without white space, headers end tag improperly read.
+            writer.writeCharacters(" ");
+        }
+    }
+    
+    /**
+     * Writes a complete set of properties to the given XML stream writer.
+     * If the value is of type string, the property will be output:
+     *    <property name="key">StringValue</property>
+     * If the value is of type box (e.g.Integer, Long) or BindingProperty, the output will be    
+     *    <property name="key" type="int">42</property>
+     */
+    private void writeBindingProperties(Map<String, BindingProperty> properties, XMLStreamWriter writer) throws XMLStreamException {
+        if (( properties == null ) || ( properties.size() == 0 )) {
+            return;
+        }
+        
+        // For both the keys and values of a map
+        for (Iterator it=properties.entrySet().iterator(); it.hasNext(); ) {
+            Map.Entry entry = (Map.Entry)it.next();
+            Object key = entry.getKey();
+            Object value = entry.getValue();
+
+            writer.writeStartElement(Constants.SCA11_NS, "property" );
+            if (key != null){
+                writer.writeAttribute("name", key.toString());
+            }
+
+            if ( value instanceof String) {
+                writer.writeCharacters( value.toString() );
+            } else if ( value instanceof BindingProperty ) {
+                BindingProperty property = (BindingProperty) value;
+                String type = property.getType();
+                if ( type != null ) {
+                   writer.writeAttribute("type", type);
+                }
+                writer.writeCharacters( property.getValue().toString() );
+            } else {
+                writer.writeCharacters( value.toString() );                
+            }
+            writer.writeEndElement();
+        }
+    }
+
+    /**
+     * Writes subscription headers if there are any.
+     *     <complexType name="messageSelection"> 
+     *         <attribute name="selector" type="string"/> 
+     *     </complexType>
+     *
+     */
+    private void writeSubscriptionHeaders( JMSBinding jmsBinding, XMLStreamWriter writer) throws XMLStreamException {
+        String jmsSubscriptionHeaders = jmsBinding.getJMSSelector();
+        if (jmsSubscriptionHeaders != null && jmsSubscriptionHeaders.length() > 0) {
+            writer.writeStartElement(Constants.SCA11_NS, "messageSelection");
+            writer.writeAttribute("selector", jmsSubscriptionHeaders);
+            writer.writeEndElement();
+            // Strange bug. Without white space, headers end tag improperly read. 
+            // writer.writeCharacters( " " ); 
+        }       
+    }
+    
+    /**
+     * Writes destination properties if there are any.
+     *     <destination jndiName="xs:anyURI" type="string"? create="string"?>
+     *         <property name="NMTOKEN" type="NMTOKEN">*
+     *     </destination>?
+     */
+    private void writeDestinationProperties( JMSBinding jmsBinding, XMLStreamWriter writer) throws XMLStreamException {       
+        String destinationName = jmsBinding.getDestinationName();
+        if (destinationName == null || (destinationName.length() < 1)) {
+            return;
+        }
+        if (destinationName == null) {
+            return;
+        }
+
+        writer.writeStartElement(Constants.SCA11_NS, "destination");
+
+        if ( destinationName != null && destinationName.length() > 0) {
+            writer.writeAttribute("jndiName", destinationName);            
+        }
+
+        // Type not handled yet
+        // String destinationType = jmsBinding.getDestinationType();
+        // if ( destinationType != null && destinationType.length() > 0) {
+        //     writer.writeAttribute("type", destinationType);            
+        // }
+
+        String destinationCreate = jmsBinding.getDestinationCreate();
+        if ( destinationCreate != null && destinationCreate.length() > 0 &&
+             !destinationCreate.equals(JMSBindingConstants.CREATE_IF_NOT_EXIST)) {
+            writer.writeAttribute("create", destinationCreate);            
+        }
+
+        Map<String, BindingProperty> destinationProperties =
+            jmsBinding.getDestinationProperties();
+        writeBindingProperties( destinationProperties, writer );            
+
+        writer.writeEndElement();
+        // Strange bug. Without white space, headers end tag improperly read.
+        writer.writeCharacters(" ");
+    }
+    
+    /**
+     * Writes connection factory properties if there are any.
+     *     <connectionFactory jndiName="xs:anyURI" create="string"?>
+     *         <property name="NMTOKEN" type="NMTOKEN">*
+     *     </connectionFactory>?
+     */
+    private void writeConnectionFactoryProperties( JMSBinding jmsBinding, XMLStreamWriter writer) throws XMLStreamException {       
+        String cfName = jmsBinding.getConnectionFactoryName();
+        if (cfName == null || (cfName.length() < 1)) {
+            return;
+        }
+
+        writer.writeStartElement(Constants.SCA11_NS, "connectionFactory");
+
+        if ( cfName != null && cfName.length() > 0) {
+            writer.writeAttribute("jndiName", cfName);            
+        }
+
+        String destinationCreate = jmsBinding.getConnectionFactoryCreate();
+        if ( destinationCreate != null && destinationCreate.length() > 0 &&
+             !destinationCreate.equals(JMSBindingConstants.CREATE_IF_NOT_EXIST)) {
+            writer.writeAttribute("create", destinationCreate);            
+        }
+
+        Map<String, BindingProperty> cfProperties =
+            jmsBinding.getConnectionFactoryProperties();
+        writeBindingProperties( cfProperties, writer );            
+
+        writer.writeEndElement();
+        // Strange bug. Without white space, headers end tag improperly read.
+        writer.writeCharacters(" ");
+    }
+    
+    /**
+     * Writes activation Spec properties if there are any.
+     *     <activationSpec name="xs:anyURI" create="string"?>
+     *         <property name="NMTOKEN" type="NMTOKEN">*
+     *     </activationSpec>?
+     * 
+     */
+    private void writeActivationSpecProperties( JMSBinding jmsBinding, XMLStreamWriter writer) throws XMLStreamException {       
+        String asName = jmsBinding.getActivationSpecName();
+        if (asName == null || (asName.length() < 1)) {
+            return;
+        }
+
+        writer.writeStartElement(Constants.SCA11_NS, "activationSpec");
+
+        if ( asName != null && asName.length() > 0) {
+            writer.writeAttribute("name", asName);            
+        }
+
+        String destinationCreate = jmsBinding.getActivationSpecCreate();
+        if ( destinationCreate != null && destinationCreate.length() > 0) {
+            writer.writeAttribute("create", destinationCreate);            
+        }
+
+        Map<String, BindingProperty> cfProperties =
+            jmsBinding.getActivationSpecProperties();
+        writeBindingProperties( cfProperties, writer );            
+
+        writer.writeEndElement();
+        // Strange bug. Without white space, headers end tag improperly read.
+        writer.writeCharacters(" ");
+    }
+    
+    /**
+     * Writes response destination properties if there are any.
+     *     <destination jndiName="xs:anyURI" type="string"? create="string"?>
+     *         <property name="NMTOKEN" type="NMTOKEN">*
+     *     </destination>?
+     */
+    private void writeResponseDestinationProperties( JMSBinding jmsBinding, XMLStreamWriter writer) throws XMLStreamException {       
+        String destinationName = jmsBinding.getResponseDestinationName();
+        if (destinationName == null || (destinationName.length() < 1)) {
+            return;
+        }
+        if (destinationName == null) {
+            return;
+        }
+
+        writer.writeStartElement(Constants.SCA11_NS, "destination");
+
+        if ( destinationName != null && destinationName.length() > 0) {
+            writer.writeAttribute("jndiName", destinationName);            
+        }
+
+        // Type not handled yet
+        // String destinationType = jmsBinding.getDestinationType();
+        // if ( destinationType != null && destinationType.length() > 0) {
+        //     writer.writeAttribute("type", destinationType);            
+        // }
+
+        String destinationCreate = jmsBinding.getResponseDestinationCreate();
+        if ( destinationCreate != null && destinationCreate.length() > 0) {
+            writer.writeAttribute("create", destinationCreate);            
+        }
+
+        Map<String, BindingProperty> destinationProperties =
+            jmsBinding.getResponseDestinationProperties();
+        writeBindingProperties( destinationProperties, writer );            
+
+        writer.writeEndElement();
+        // Strange bug. Without white space, headers end tag improperly read.
+        writer.writeCharacters(" ");
+    }
+    
+    /**
+     * Writes response connection factory properties if there are any.
+     *     <connectionFactory jndiName="xs:anyURI" create="string"?>
+     *         <property name="NMTOKEN" type="NMTOKEN">*
+     *     </connectionFactory>?
+     * 
+     */
+    private void writeResponseConnectionFactoryProperties( JMSBinding jmsBinding, XMLStreamWriter writer) throws XMLStreamException {       
+        String cfName = jmsBinding.getResponseConnectionFactoryName();
+        if (cfName == null || (cfName.length() < 1)) {
+            return;
+        }
+
+        writer.writeStartElement(Constants.SCA11_NS, "connectionFactory");
+
+        if ( cfName != null && cfName.length() > 0) {
+            writer.writeAttribute("jndiName", cfName);            
+        }
+
+        String destinationCreate = jmsBinding.getResponseConnectionFactoryCreate();
+        if ( destinationCreate != null && destinationCreate.length() > 0) {
+            writer.writeAttribute("create", destinationCreate);            
+        }
+
+        Map<String, BindingProperty> cfProperties =
+            jmsBinding.getResponseConnectionFactoryProperties();
+        writeBindingProperties( cfProperties, writer );            
+
+        writer.writeEndElement();
+        // Strange bug. Without white space, headers end tag improperly read.
+        writer.writeCharacters(" ");
+    }
+    
+    /**
+     * Writes response activation Spec properties if there are any.
+     *     <activationSpec name="xs:anyURI" create="string"?>
+     *         <property name="NMTOKEN" type="NMTOKEN">*
+     *     </activationSpec>?
+     * 
+     */
+    private void writeResponseActivationSpecProperties( JMSBinding jmsBinding, XMLStreamWriter writer) throws XMLStreamException {       
+        String asName = jmsBinding.getResponseActivationSpecName();
+        if (asName == null || (asName.length() < 1)) {
+            return;
+        }
+
+        writer.writeStartElement(Constants.SCA11_NS, "activationSpec");
+
+        if ( asName != null && asName.length() > 0) {
+            writer.writeAttribute("name", asName);            
+        }
+
+        String destinationCreate = jmsBinding.getResponseActivationSpecCreate();
+        if ( destinationCreate != null && destinationCreate.length() > 0) {
+            writer.writeAttribute("create", destinationCreate);            
+        }
+
+        Map<String, BindingProperty> cfProperties =
+            jmsBinding.getResponseActivationSpecProperties();
+        writeBindingProperties( cfProperties, writer );            
+
+        writer.writeEndElement();
+        // Strange bug. Without white space, headers end tag improperly read.
+        writer.writeCharacters(" ");
+    }  
+
+    /**
+     * Writes resource adapter properties if there are any.
+     *    <resourceAdapter name="NMTOKEN">?
+     *         <property name="NMTOKEN" type="NMTOKEN">*
+     *    </resourceAdapter>? 
+     */
+    private void writeResourceAdapterProperties( JMSBinding jmsBinding, XMLStreamWriter writer) throws XMLStreamException {       
+        String asName = jmsBinding.getResourceAdapterName();
+        if (asName == null || (asName.length() < 1)) {
+            return;
+        }
+
+        writer.writeStartElement(Constants.SCA11_NS, "resourceAdapter");
+
+        if ( asName != null && asName.length() > 0) {
+            writer.writeAttribute("name", asName);            
+        }
+
+        Map<String, BindingProperty> cfProperties =
+            jmsBinding.getResourceAdapterProperties();
+        writeBindingProperties( cfProperties, writer );            
+
+        writer.writeEndElement();
+        // Strange bug. Without white space, headers end tag improperly read.
+        writer.writeCharacters(" ");
+    }
+    
+    /**
+     * Writes configured operations if there are any.
+     *  <binding.jms uri=\"jms:testQueue\" >"
+     *      <operationProperties name=\"op1\">"
+     *      </operationProperties >" 
+     *       <operation name=\"op1\" requires=\"IntentOne IntentTwo\"/>"
+     *   </binding.jms>"
+     */
+    private void writeConfiguredOperations( JMSBinding jmsBinding, XMLStreamWriter writer, ProcessorContext context) throws XMLStreamException, ContributionWriteException {       
+        List<ConfiguredOperation> configOps = jmsBinding.getConfiguredOperations();
+        if (configOps == null || (configOps.size() < 1)) {
+            return;
+        }
+
+        for( Iterator<ConfiguredOperation> it = configOps.iterator(); it.hasNext();) {
+           configuredOperationProcessor.write(it.next(), writer, context);
+        }
+
+        // Strange bug. Without white space, headers end tag improperly read.
+        writer.writeCharacters(" ");
+    }
+    
+    /**
+     * Wire out a request or response wire format element. Uses extension processors
+     * to do this as wire format is an extension point
+     * 
+     * @param wireFormat
+     * @param writer
+     */
+    private void writeWireFormat(WireFormat wireFormat, XMLStreamWriter writer, ProcessorContext context ) throws XMLStreamException, ContributionWriteException {
+        extensionProcessor.write(wireFormat, writer, context);
+    }
+    
+    /**
+     * Wire out an operation selector element. Uses extension processors
+     * to do this as operation selector is an extension point
+     * 
+     * @param operationSeletor
+     * @param writer
+     */
+    private void writeOperationSelector(OperationSelector operationSeletor, XMLStreamWriter writer, ProcessorContext context ) throws XMLStreamException, ContributionWriteException{
+        extensionProcessor.write(operationSeletor, writer, context);        
+    }
+    
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSDefault.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSDefault.java
new file mode 100644
index 0000000000..a02decd20f
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSDefault.java
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms.operationselector;
+
+import javax.xml.namespace.QName;
+
+import org.apache.tuscany.sca.assembly.OperationSelector;
+import org.apache.tuscany.sca.assembly.xml.Constants;
+
+/**
+ * Implementation for policies that could be injected as parameter
+ * into the axis2config.
+ *
+ * @version $Rev$ $Date$
+ */
+public class OperationSelectorJMSDefault implements OperationSelector {
+    public static final QName OPERATION_SELECTOR_JMS_DEFAULT_QNAME = new QName(Constants.SCA11_TUSCANY_NS, "operationSelector.jmsdefault");
+    
+    public QName getSchemaName() {
+        return OPERATION_SELECTOR_JMS_DEFAULT_QNAME;
+    }
+
+    public boolean isUnresolved() {
+        return false;
+    }
+
+    public void setUnresolved(boolean unresolved) {
+    }
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSDefaultProcessor.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSDefaultProcessor.java
new file mode 100644
index 0000000000..4f09eeb9a5
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSDefaultProcessor.java
@@ -0,0 +1,76 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms.operationselector;
+
+
+import javax.xml.namespace.QName;
+import javax.xml.stream.XMLStreamException;
+import javax.xml.stream.XMLStreamReader;
+import javax.xml.stream.XMLStreamWriter;
+
+import org.apache.tuscany.sca.assembly.xml.Constants;
+import org.apache.tuscany.sca.contribution.processor.BaseStAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.processor.ContributionReadException;
+import org.apache.tuscany.sca.contribution.processor.ContributionResolveException;
+import org.apache.tuscany.sca.contribution.processor.ContributionWriteException;
+import org.apache.tuscany.sca.contribution.processor.ProcessorContext;
+import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.resolver.ModelResolver;
+import org.apache.tuscany.sca.core.FactoryExtensionPoint;
+
+/**
+ *
+ * @version $Rev$ $Date$
+ */
+public class OperationSelectorJMSDefaultProcessor extends BaseStAXArtifactProcessor implements StAXArtifactProcessor<OperationSelectorJMSDefault> {
+    
+    public QName getArtifactType() {
+        return OperationSelectorJMSDefault.OPERATION_SELECTOR_JMS_DEFAULT_QNAME;
+    }
+    
+    public OperationSelectorJMSDefaultProcessor(FactoryExtensionPoint modelFactories) {
+    }
+
+    
+    public OperationSelectorJMSDefault read(XMLStreamReader reader, ProcessorContext context) throws ContributionReadException, XMLStreamException {
+        OperationSelectorJMSDefault wireFormat = new OperationSelectorJMSDefault();
+         
+        return wireFormat;
+    }
+
+    public void write(OperationSelectorJMSDefault wireFormat, XMLStreamWriter writer, ProcessorContext context) 
+        throws ContributionWriteException, XMLStreamException {
+        String prefix = "tuscany";
+        writer.writeStartElement(prefix, 
+                                 getArtifactType().getLocalPart(),
+                                 getArtifactType().getNamespaceURI());
+        writer.writeNamespace("tuscany", Constants.SCA11_TUSCANY_NS); 
+        
+        writer.writeEndElement();
+    }
+
+    public Class<OperationSelectorJMSDefault> getModelType() {
+        return OperationSelectorJMSDefault.class;
+    }
+
+    public void resolve(OperationSelectorJMSDefault arg0, ModelResolver arg1, ProcessorContext context) throws ContributionResolveException {
+
+    }
+    
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSUserProp.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSUserProp.java
new file mode 100644
index 0000000000..f978adfa58
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSUserProp.java
@@ -0,0 +1,57 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms.operationselector;
+
+import javax.xml.namespace.QName;
+
+import org.apache.tuscany.sca.assembly.OperationSelector;
+import org.apache.tuscany.sca.assembly.xml.Constants;
+
+/**
+ * Model of user property based operation selection
+ * 
+ * <operationSelector.jmsUser propertName="MyHeaderProperty"/>
+ *
+ * @version $Rev$ $Date$
+ */
+public class OperationSelectorJMSUserProp implements OperationSelector {
+    public static final QName OPERATION_SELECTOR_JMS_USERPROP_QNAME = new QName(Constants.SCA11_TUSCANY_NS, "operationSelector.jmsUserProp");
+    public static final String OPERATION_SELECTOR_JMS_USERPROP_ATTR  = "propertyName";
+    
+    private String propertyName;
+    
+    public QName getSchemaName() {
+        return OPERATION_SELECTOR_JMS_USERPROP_QNAME;
+    }
+
+    public boolean isUnresolved() {
+        return false;
+    }
+
+    public void setUnresolved(boolean unresolved) {
+    }
+
+    public String getPropertyName() {
+        return propertyName;
+    }
+
+    public void setPropertyName(String propertyName) {
+        this.propertyName = propertyName;
+    }
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSUserPropProcessor.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSUserPropProcessor.java
new file mode 100644
index 0000000000..9b731ffb1b
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSUserPropProcessor.java
@@ -0,0 +1,87 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms.operationselector;
+
+
+import javax.xml.namespace.QName;
+import javax.xml.stream.XMLStreamException;
+import javax.xml.stream.XMLStreamReader;
+import javax.xml.stream.XMLStreamWriter;
+
+import org.apache.tuscany.sca.assembly.xml.Constants;
+import org.apache.tuscany.sca.contribution.processor.BaseStAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.processor.ContributionReadException;
+import org.apache.tuscany.sca.contribution.processor.ContributionResolveException;
+import org.apache.tuscany.sca.contribution.processor.ContributionWriteException;
+import org.apache.tuscany.sca.contribution.processor.ProcessorContext;
+import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.resolver.ModelResolver;
+import org.apache.tuscany.sca.core.FactoryExtensionPoint;
+
+/**
+ *
+ * @version $Rev$ $Date$
+ */
+public class OperationSelectorJMSUserPropProcessor extends BaseStAXArtifactProcessor implements StAXArtifactProcessor<OperationSelectorJMSUserProp> {
+    
+    public QName getArtifactType() {
+        return OperationSelectorJMSUserProp.OPERATION_SELECTOR_JMS_USERPROP_QNAME;
+    }
+    
+    public OperationSelectorJMSUserPropProcessor(FactoryExtensionPoint modelFactories) {
+    }
+
+    
+    public OperationSelectorJMSUserProp read(XMLStreamReader reader, ProcessorContext context) throws ContributionReadException, XMLStreamException {
+        OperationSelectorJMSUserProp opSelector = new OperationSelectorJMSUserProp();
+        String propertyName = reader.getAttributeValue(null, OperationSelectorJMSUserProp.OPERATION_SELECTOR_JMS_USERPROP_ATTR);
+        if (propertyName != null && propertyName.length() > 0) {
+            opSelector.setPropertyName(propertyName);
+        } else {
+            throw new ContributionReadException(OperationSelectorJMSUserProp.OPERATION_SELECTOR_JMS_USERPROP_QNAME.toString() + ": " + 
+                    OperationSelectorJMSUserProp.OPERATION_SELECTOR_JMS_USERPROP_ATTR + " is a required attribute.");
+        }
+        
+        return opSelector;
+    }
+
+    public void write(OperationSelectorJMSUserProp opSelector, XMLStreamWriter writer, ProcessorContext context) 
+        throws ContributionWriteException, XMLStreamException {
+        String prefix = "tuscany";
+        writer.writeStartElement(prefix, 
+                                 getArtifactType().getLocalPart(),
+                                 getArtifactType().getNamespaceURI());
+        writer.writeNamespace("tuscany", Constants.SCA11_TUSCANY_NS); 
+        
+        if (opSelector.getPropertyName() != null) {
+            writer.writeAttribute(OperationSelectorJMSUserProp.OPERATION_SELECTOR_JMS_USERPROP_ATTR, opSelector.getPropertyName());
+        }
+        
+        writer.writeEndElement();
+    }
+
+    public Class<OperationSelectorJMSUserProp> getModelType() {
+        return OperationSelectorJMSUserProp.class;
+    }
+
+    public void resolve(OperationSelectorJMSUserProp arg0, ModelResolver arg1, ProcessorContext context) throws ContributionResolveException {
+
+    }
+    
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/authentication/token/JMSTokenAuthenticationPolicy.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/authentication/token/JMSTokenAuthenticationPolicy.java
new file mode 100644
index 0000000000..24f43d3027
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/authentication/token/JMSTokenAuthenticationPolicy.java
@@ -0,0 +1,55 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms.policy.authentication.token;
+
+import javax.xml.namespace.QName;
+
+import org.apache.tuscany.sca.assembly.xml.Constants;
+
+/**
+ * Implementation for policies that could be injected as parameter
+ * into the axis2config.
+ *
+ * @version $Rev$ $Date$
+ */
+public class JMSTokenAuthenticationPolicy {
+    public static final QName JMS_TOKEN_AUTHENTICATION_POLICY_QNAME = new QName(Constants.SCA11_TUSCANY_NS, "jmsTokenAuthentication");
+    public static final String JMS_TOKEN_AUTHENTICATION_TOKEN_NAME = "tokenName";
+
+    private QName tokenName;
+
+    public QName getTokenName() {
+        return tokenName;
+    }
+    
+    public void setTokenName(QName tokenName) {
+        this.tokenName = tokenName;
+    }
+    
+    public QName getSchemaName() {
+        return JMS_TOKEN_AUTHENTICATION_POLICY_QNAME;
+    }
+
+    public boolean isUnresolved() {
+        return false;
+    }
+
+    public void setUnresolved(boolean unresolved) {
+    }
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/authentication/token/JMSTokenAuthenticationPolicyProcessor.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/authentication/token/JMSTokenAuthenticationPolicyProcessor.java
new file mode 100644
index 0000000000..4322595515
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/authentication/token/JMSTokenAuthenticationPolicyProcessor.java
@@ -0,0 +1,111 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms.policy.authentication.token;
+
+import static javax.xml.stream.XMLStreamConstants.END_ELEMENT;
+import static javax.xml.stream.XMLStreamConstants.START_ELEMENT;
+
+import javax.xml.namespace.QName;
+import javax.xml.stream.XMLStreamException;
+import javax.xml.stream.XMLStreamReader;
+import javax.xml.stream.XMLStreamWriter;
+
+import org.apache.tuscany.sca.assembly.xml.Constants;
+import org.apache.tuscany.sca.contribution.processor.BaseStAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.processor.ContributionReadException;
+import org.apache.tuscany.sca.contribution.processor.ContributionResolveException;
+import org.apache.tuscany.sca.contribution.processor.ContributionWriteException;
+import org.apache.tuscany.sca.contribution.processor.ProcessorContext;
+import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.resolver.ModelResolver;
+import org.apache.tuscany.sca.core.ExtensionPointRegistry;
+
+/**
+ *
+ * @version $Rev$ $Date$
+ */
+public class JMSTokenAuthenticationPolicyProcessor extends BaseStAXArtifactProcessor implements StAXArtifactProcessor<JMSTokenAuthenticationPolicy> {
+    
+    public QName getArtifactType() {
+        return JMSTokenAuthenticationPolicy.JMS_TOKEN_AUTHENTICATION_POLICY_QNAME;
+    }
+    
+    public JMSTokenAuthenticationPolicyProcessor(ExtensionPointRegistry registry) {
+    }
+
+    
+    public JMSTokenAuthenticationPolicy read(XMLStreamReader reader, ProcessorContext context) throws ContributionReadException, XMLStreamException {
+        JMSTokenAuthenticationPolicy policy = new JMSTokenAuthenticationPolicy();
+        int event = reader.getEventType();
+        QName name = null;
+        
+        while (reader.hasNext()) {
+            event = reader.getEventType();
+            switch (event) {
+                case START_ELEMENT : {
+                    name = reader.getName();
+                    if ( name.equals(getArtifactType()) ) {
+                        policy.setTokenName(getQName(reader, JMSTokenAuthenticationPolicy.JMS_TOKEN_AUTHENTICATION_TOKEN_NAME));
+                    } 
+                    break;
+                }
+            }
+            
+            if ( event == END_ELEMENT ) {
+                if ( getArtifactType().equals(reader.getName()) ) {
+                    break;
+                } 
+            }
+            
+            //Read the next element
+            if (reader.hasNext()) {
+                reader.next();
+            }
+        }
+         
+        return policy;
+    }
+
+    public void write(JMSTokenAuthenticationPolicy policy, XMLStreamWriter writer, ProcessorContext context) 
+        throws ContributionWriteException, XMLStreamException {
+        String prefix = "tuscany";
+        writer.writeStartElement(prefix, 
+                                 getArtifactType().getLocalPart(),
+                                 getArtifactType().getNamespaceURI());
+        writer.writeNamespace("tuscany", Constants.SCA11_TUSCANY_NS);
+
+        if ( policy.getTokenName() != null ) {
+            writer.writeAttribute(prefix,
+                                  getArtifactType().getNamespaceURI(),
+                                  JMSTokenAuthenticationPolicy.JMS_TOKEN_AUTHENTICATION_TOKEN_NAME, 
+                                  policy.getTokenName().toString());
+        }      
+        
+        writer.writeEndElement();
+    }
+
+    public Class<JMSTokenAuthenticationPolicy> getModelType() {
+        return JMSTokenAuthenticationPolicy.class;
+    }
+
+    public void resolve(JMSTokenAuthenticationPolicy arg0, ModelResolver arg1, ProcessorContext context) throws ContributionResolveException {
+
+    }
+    
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/header/JMSHeaderPolicy.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/header/JMSHeaderPolicy.java
new file mode 100644
index 0000000000..48fef397c7
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/header/JMSHeaderPolicy.java
@@ -0,0 +1,130 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms.policy.header;
+
+import java.util.Hashtable;
+import java.util.Map;
+
+import javax.xml.namespace.QName;
+
+import org.apache.tuscany.sca.assembly.xml.Constants;
+
+/**
+ * Implementation for policies that could be injected as parameter
+ * into the axis2config.
+ *
+ * @version $Rev$ $Date$
+ */
+public class JMSHeaderPolicy {
+    public static final QName JMS_HEADER_POLICY_QNAME = new QName(Constants.SCA11_TUSCANY_NS, "jmsHeader");
+    public static final String JMS_HEADER_JMS_TYPE = "JMSType";
+    public static final String JMS_HEADER_JMS_CORRELATION_ID = "JMSCorrelationID";
+    public static final String JMS_HEADER_JMS_DELIVERY_MODE = "JMSDeliveryMode";
+    public static final String JMS_HEADER_JMS_TIME_TO_LIVE = "JMSTimeToLive";
+    public static final String JMS_HEADER_JMS_PRIORITY = "JMSPriority";
+    public static final String JMS_HEADER_JMS_PROPERTY = "property";
+    public static final String JMS_HEADER_JMS_PROPERTY_NAME = "name";
+
+    private String jmsType = null;
+    private String jmsCorrelationId = null;
+    private Boolean deliveryModePersistent = null;
+    private Long timeToLive = null;
+    private Integer jmsPriority = null;
+    private Map<String, String> properties = new Hashtable<String, String>();
+    
+    public String getJmsType() {
+        return jmsType;
+    }
+    
+    public void setJmsType(String jmsType) {
+        this.jmsType = jmsType;
+    }
+    
+    public String getJmsCorrelationId() {
+        return jmsCorrelationId;
+    }
+    
+    public void setJmsCorrelationId(String jmsCorrelationId) {
+        this.jmsCorrelationId = jmsCorrelationId;
+    }
+    
+    public Boolean getDeliveryModePersistent() {
+        return deliveryModePersistent;
+    }
+    
+    public void setDeliveryModePersistent(Boolean deliveryModePersistent) {
+        this.deliveryModePersistent = deliveryModePersistent;
+    }
+    
+    public Long getTimeToLive() {
+        return timeToLive;
+    }
+    
+    public void setTimeToLive(Long timeToLive) {
+        this.timeToLive = timeToLive;
+    }
+    
+    public Integer getJmsPriority() {
+        return jmsPriority;
+    }
+    
+    public void setJmsPriority(Integer jmsPriority) {
+        this.jmsPriority = jmsPriority;
+    }
+    
+    public Map<String, String> getProperties() {
+        return properties;
+    }
+  
+    public QName getSchemaName() {
+        return JMS_HEADER_POLICY_QNAME;
+    }
+
+    public boolean isUnresolved() {
+        return false;
+    }
+
+    public void setUnresolved(boolean unresolved) {
+    }
+    
+    @Override
+    public String toString() {
+        String result = "jmsHeader";
+        
+        result += " JMSType ";
+        result += getJmsType();
+        result += " JMSDeliveryMode ";
+        result += getJmsCorrelationId();
+        result += " JMSDeliveryMode ";
+        result += getDeliveryModePersistent();
+        result += " JMSTimeToLive ";
+        result += getTimeToLive();
+        result += " JMSPriority ";
+        result += getJmsPriority();
+        
+        for (String propertyName : properties.keySet()){
+            result += " property ";
+            result += propertyName;
+            result += " ";
+            result += properties.get(propertyName);
+        }
+        
+        return result;
+    }
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/header/JMSHeaderPolicyProcessor.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/header/JMSHeaderPolicyProcessor.java
new file mode 100644
index 0000000000..c925c01554
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/header/JMSHeaderPolicyProcessor.java
@@ -0,0 +1,206 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms.policy.header;
+
+import static javax.xml.stream.XMLStreamConstants.END_ELEMENT;
+import static javax.xml.stream.XMLStreamConstants.START_ELEMENT;
+
+import javax.xml.namespace.QName;
+import javax.xml.stream.XMLStreamException;
+import javax.xml.stream.XMLStreamReader;
+import javax.xml.stream.XMLStreamWriter;
+
+import org.apache.tuscany.sca.assembly.xml.Constants;
+import org.apache.tuscany.sca.assembly.xml.Messages;
+import org.apache.tuscany.sca.contribution.processor.BaseStAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.processor.ContributionReadException;
+import org.apache.tuscany.sca.contribution.processor.ContributionResolveException;
+import org.apache.tuscany.sca.contribution.processor.ContributionWriteException;
+import org.apache.tuscany.sca.contribution.processor.ProcessorContext;
+import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.resolver.ModelResolver;
+import org.apache.tuscany.sca.core.ExtensionPointRegistry;
+import org.apache.tuscany.sca.monitor.Monitor;
+import org.apache.tuscany.sca.monitor.Problem;
+import org.apache.tuscany.sca.monitor.Problem.Severity;
+
+/**
+ *
+ * @version $Rev$ $Date$
+ */
+public class JMSHeaderPolicyProcessor extends BaseStAXArtifactProcessor implements StAXArtifactProcessor<JMSHeaderPolicy> {
+    
+    
+    
+    public QName getArtifactType() {
+        return JMSHeaderPolicy.JMS_HEADER_POLICY_QNAME;
+    }
+    
+    public JMSHeaderPolicyProcessor(ExtensionPointRegistry modelFactories) {
+    }
+    
+    /**
+     * Marshals warnings into the monitor
+     * 
+     * @param message
+     * @param model
+     * @param messageParameters
+     */
+    protected void warning(Monitor monitor, String message, Object model, String... messageParameters) {
+        if (monitor != null){
+            Problem problem = monitor.createProblem(this.getClass().getName(), Messages.RESOURCE_BUNDLE, Severity.WARNING, model, message, (Object[])messageParameters);
+            monitor.problem(problem);
+        }
+    }
+    
+    /**
+     * Marshals errors into the monitor
+     * 
+     * @param problems
+     * @param message
+     * @param model
+     */
+    protected void error(Monitor monitor, String message, Object model, Object... messageParameters) {
+        if (monitor != null) {
+            Problem problem = monitor.createProblem(this.getClass().getName(), Messages.RESOURCE_BUNDLE, Severity.ERROR, model, message, (Object[])messageParameters);
+            monitor.problem(problem);
+        }
+    }    
+
+    
+    public JMSHeaderPolicy read(XMLStreamReader reader, ProcessorContext context) throws ContributionReadException, XMLStreamException {
+        JMSHeaderPolicy policy = new JMSHeaderPolicy();
+        int event = reader.getEventType();
+        QName name = null;
+        Monitor monitor = context.getMonitor();
+        while (reader.hasNext()) {
+            event = reader.getEventType();
+            switch (event) {
+                case START_ELEMENT : {
+                    name = reader.getName();
+                    if ( name.equals(getArtifactType()) ) {
+                        
+                        policy.setJmsType(getString(reader, JMSHeaderPolicy.JMS_HEADER_JMS_TYPE));
+                        policy.setJmsCorrelationId(getString(reader, JMSHeaderPolicy.JMS_HEADER_JMS_CORRELATION_ID));
+                        
+                        String deliveryMode = getString(reader, JMSHeaderPolicy.JMS_HEADER_JMS_DELIVERY_MODE);
+                        if (deliveryMode != null){
+                            if (deliveryMode.equals("PERSISTENT")) {
+                                policy.setDeliveryModePersistent(true);
+                            } else if (deliveryMode.equals("NON_PERSISTENT")){
+                                policy.setDeliveryModePersistent(false);
+                            } else {
+                                error(monitor, "InvalidDeliveryMode", policy, deliveryMode);
+                            }  
+                        }
+                        
+                        String timeToLive = getString(reader, JMSHeaderPolicy.JMS_HEADER_JMS_TIME_TO_LIVE);
+                        
+                        if ( timeToLive != null){
+                            try {
+                                policy.setTimeToLive(Long.valueOf(timeToLive));
+                            } catch (NumberFormatException ex){
+                                error(monitor, "InvalidTimeToLive", policy, timeToLive);
+                            }
+                        }
+                        
+                        String priority = getString(reader, JMSHeaderPolicy.JMS_HEADER_JMS_PRIORITY);
+                        
+                        if ( priority != null){
+                            try {
+                                policy.setJmsPriority(Integer.valueOf(priority));
+                            } catch (NumberFormatException ex){
+                                error(monitor, "InvalidPriority", policy, priority);
+                            }                                
+                        }
+                    } else if (name.getLocalPart().equals(JMSHeaderPolicy.JMS_HEADER_JMS_PROPERTY)) {
+                        String propertyName = getString(reader, JMSHeaderPolicy.JMS_HEADER_JMS_PROPERTY_NAME);
+                        String propertyValue = reader.getElementText();
+                        policy.getProperties().put(propertyName, propertyValue);
+                    } 
+                    break;
+                }
+            }
+            
+            if ( event == END_ELEMENT ) {
+                if ( getArtifactType().equals(reader.getName()) ) {
+                    break;
+                } 
+            }
+            
+            //Read the next element
+            if (reader.hasNext()) {
+                reader.next();
+            }
+        }
+         
+        return policy;
+    }
+
+    public void write(JMSHeaderPolicy policy, XMLStreamWriter writer, ProcessorContext context) 
+        throws ContributionWriteException, XMLStreamException {
+        String prefix = "tuscany";
+        writer.writeStartElement(prefix, 
+                                 getArtifactType().getLocalPart(),
+                                 getArtifactType().getNamespaceURI());
+        writer.writeNamespace("tuscany", Constants.SCA11_TUSCANY_NS);
+        
+        if (policy.getJmsType() != null){
+            writer.writeAttribute(JMSHeaderPolicy.JMS_HEADER_JMS_TYPE, policy.getJmsType());
+        }
+        
+        if (policy.getJmsCorrelationId() != null){
+            writer.writeAttribute(JMSHeaderPolicy.JMS_HEADER_JMS_CORRELATION_ID, policy.getJmsCorrelationId());
+        } 
+        
+        if (policy.getDeliveryModePersistent() == true){
+            writer.writeAttribute(JMSHeaderPolicy.JMS_HEADER_JMS_DELIVERY_MODE, "PERSISTENT");
+        } else {
+            writer.writeAttribute(JMSHeaderPolicy.JMS_HEADER_JMS_DELIVERY_MODE, "NON_PERSISTENT");
+        }
+        
+        if (policy.getTimeToLive()!= null){
+            writer.writeAttribute(JMSHeaderPolicy.JMS_HEADER_JMS_TIME_TO_LIVE, policy.getTimeToLive().toString());
+        }    
+        
+        if (policy.getJmsPriority()!= null){
+            writer.writeAttribute(JMSHeaderPolicy.JMS_HEADER_JMS_PRIORITY, policy.getJmsPriority().toString());
+        }          
+        
+        for (String propertyName : policy.getProperties().keySet()){
+            writer.writeStartElement(prefix, 
+                                     JMSHeaderPolicy.JMS_HEADER_JMS_PROPERTY,
+                                     getArtifactType().getNamespaceURI());
+            writer.writeAttribute(JMSHeaderPolicy.JMS_HEADER_JMS_PROPERTY_NAME, propertyName);
+            writer.writeCharacters(policy.getProperties().get(propertyName));
+            writer.writeEndElement();
+        }    
+        
+        writer.writeEndElement();
+    }
+
+    public Class<JMSHeaderPolicy> getModelType() {
+        return JMSHeaderPolicy.class;
+    }
+
+    public void resolve(JMSHeaderPolicy arg0, ModelResolver arg1, ProcessorContext context) throws ContributionResolveException {
+
+    }
+    
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytes.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytes.java
new file mode 100644
index 0000000000..a16cdc9c4f
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytes.java
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms.wireformat;
+
+import javax.xml.namespace.QName;
+
+import org.apache.tuscany.sca.assembly.WireFormat;
+import org.apache.tuscany.sca.assembly.xml.Constants;
+
+/**
+ * Implementation for policies that could be injected as parameter
+ * into the axis2config.
+ *
+ * @version $Rev$ $Date$
+ */
+public class WireFormatJMSBytes implements WireFormat {
+    public static final QName WIRE_FORMAT_JMS_BYTES_QNAME = new QName(Constants.SCA11_TUSCANY_NS, "wireFormat.jmsBytes");
+    
+    public QName getSchemaName() {
+        return WIRE_FORMAT_JMS_BYTES_QNAME;
+    }
+
+    public boolean isUnresolved() {
+        return false;
+    }
+
+    public void setUnresolved(boolean unresolved) {
+    }
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytesProcessor.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytesProcessor.java
new file mode 100644
index 0000000000..8be904da3e
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytesProcessor.java
@@ -0,0 +1,75 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms.wireformat;
+
+import javax.xml.namespace.QName;
+import javax.xml.stream.XMLStreamException;
+import javax.xml.stream.XMLStreamReader;
+import javax.xml.stream.XMLStreamWriter;
+
+import org.apache.tuscany.sca.assembly.xml.Constants;
+import org.apache.tuscany.sca.contribution.processor.BaseStAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.processor.ContributionReadException;
+import org.apache.tuscany.sca.contribution.processor.ContributionResolveException;
+import org.apache.tuscany.sca.contribution.processor.ContributionWriteException;
+import org.apache.tuscany.sca.contribution.processor.ProcessorContext;
+import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.resolver.ModelResolver;
+import org.apache.tuscany.sca.core.FactoryExtensionPoint;
+
+/**
+ *
+ * @version $Rev$ $Date$
+ */
+public class WireFormatJMSBytesProcessor extends BaseStAXArtifactProcessor implements StAXArtifactProcessor<WireFormatJMSBytes> {
+    
+    public QName getArtifactType() {
+        return WireFormatJMSBytes.WIRE_FORMAT_JMS_BYTES_QNAME;
+    }
+    
+    public WireFormatJMSBytesProcessor(FactoryExtensionPoint modelFactories) {
+    }
+
+    
+    public WireFormatJMSBytes read(XMLStreamReader reader, ProcessorContext context) throws ContributionReadException, XMLStreamException {
+        WireFormatJMSBytes wireFormat = new WireFormatJMSBytes();
+         
+        return wireFormat;
+    }
+
+    public void write(WireFormatJMSBytes wireFormat, XMLStreamWriter writer, ProcessorContext context) 
+        throws ContributionWriteException, XMLStreamException {
+        String prefix = "tuscany";
+        writer.writeStartElement(prefix, 
+                                 getArtifactType().getLocalPart(),
+                                 getArtifactType().getNamespaceURI());
+        writer.writeNamespace("tuscany", Constants.SCA11_TUSCANY_NS); 
+        
+        writer.writeEndElement();
+    }
+
+    public Class<WireFormatJMSBytes> getModelType() {
+        return WireFormatJMSBytes.class;
+    }
+
+    public void resolve(WireFormatJMSBytes arg0, ModelResolver arg1, ProcessorContext context) throws ContributionResolveException {
+
+    }
+    
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytesXML.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytesXML.java
new file mode 100644
index 0000000000..4f7a91657f
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytesXML.java
@@ -0,0 +1,40 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms.wireformat;
+
+import javax.xml.namespace.QName;
+
+import org.apache.tuscany.sca.assembly.WireFormat;
+import org.apache.tuscany.sca.assembly.xml.Constants;
+
+
+public class WireFormatJMSBytesXML implements WireFormat {
+    public static final QName WIRE_FORMAT_JMS_BYTES_QNAME = new QName(Constants.SCA11_TUSCANY_NS, "wireFormat.jmsBytesXML");
+    
+    public QName getSchemaName() {
+        return WIRE_FORMAT_JMS_BYTES_QNAME;
+    }
+
+    public boolean isUnresolved() {
+        return false;
+    }
+
+    public void setUnresolved(boolean unresolved) {
+    }
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytesXMLProcessor.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytesXMLProcessor.java
new file mode 100644
index 0000000000..33533b23eb
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytesXMLProcessor.java
@@ -0,0 +1,72 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms.wireformat;
+
+import javax.xml.namespace.QName;
+import javax.xml.stream.XMLStreamException;
+import javax.xml.stream.XMLStreamReader;
+import javax.xml.stream.XMLStreamWriter;
+
+import org.apache.tuscany.sca.assembly.xml.Constants;
+import org.apache.tuscany.sca.contribution.processor.BaseStAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.processor.ContributionReadException;
+import org.apache.tuscany.sca.contribution.processor.ContributionResolveException;
+import org.apache.tuscany.sca.contribution.processor.ContributionWriteException;
+import org.apache.tuscany.sca.contribution.processor.ProcessorContext;
+import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.resolver.ModelResolver;
+import org.apache.tuscany.sca.core.FactoryExtensionPoint;
+
+
+public class WireFormatJMSBytesXMLProcessor extends BaseStAXArtifactProcessor implements StAXArtifactProcessor<WireFormatJMSBytesXML> {
+    
+    public QName getArtifactType() {
+        return WireFormatJMSBytesXML.WIRE_FORMAT_JMS_BYTES_QNAME;
+    }
+    
+    public WireFormatJMSBytesXMLProcessor(FactoryExtensionPoint modelFactories) {
+    }
+
+    
+    public WireFormatJMSBytesXML read(XMLStreamReader reader, ProcessorContext context) throws ContributionReadException, XMLStreamException {
+        WireFormatJMSBytesXML wireFormat = new WireFormatJMSBytesXML();
+         
+        return wireFormat;
+    }
+
+    public void write(WireFormatJMSBytesXML wireFormat, XMLStreamWriter writer, ProcessorContext context) 
+        throws ContributionWriteException, XMLStreamException {
+        String prefix = "tuscany";
+        writer.writeStartElement(prefix, 
+                                 getArtifactType().getLocalPart(),
+                                 getArtifactType().getNamespaceURI());
+        writer.writeNamespace("tuscany", Constants.SCA11_TUSCANY_NS); 
+        
+        writer.writeEndElement();
+    }
+
+    public Class<WireFormatJMSBytesXML> getModelType() {
+        return WireFormatJMSBytesXML.class;
+    }
+
+    public void resolve(WireFormatJMSBytesXML arg0, ModelResolver arg1, ProcessorContext context) throws ContributionResolveException {
+
+    }
+    
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSDefault.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSDefault.java
new file mode 100644
index 0000000000..5c33a3e2c8
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSDefault.java
@@ -0,0 +1,64 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms.wireformat;
+
+import javax.xml.namespace.QName;
+
+import org.apache.tuscany.sca.assembly.WireFormat;
+import org.apache.tuscany.sca.assembly.xml.Constants;
+
+/**
+ * 
+ * @version $Rev$ $Date$
+ */
+public class WireFormatJMSDefault implements WireFormat {
+    public static final QName WIRE_FORMAT_JMS_DEFAULT_QNAME = new QName(Constants.SCA11_TUSCANY_NS, "wireFormat.jmsdefault");
+    
+    public static final String WIRE_FORMAT_JMS_DEFAULT_FORMAT_ATTR = "sendFormat";
+    
+    public static final String WIRE_FORMAT_JMS_DEFAULT_TEXT_FORMAT_VAL = "text";
+    public static final String WIRE_FORMAT_JMS_DEFAULT_BYTES_FORMAT_VAL = "bytes";
+
+    //default is to use a javax.jms.BytesMessage
+    private boolean useBytesMessage = true;
+    
+    public QName getSchemaName() {
+        return WIRE_FORMAT_JMS_DEFAULT_QNAME;
+    }
+
+    public boolean isUnresolved() {
+        return false;
+    }
+
+    public void setUnresolved(boolean unresolved) {
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        return this.getClass() == obj.getClass();
+    }
+    
+    public void setUseBytesMessage(boolean useBytesMessage) {
+        this.useBytesMessage = useBytesMessage;
+    }
+
+    public boolean isUseBytesMessage() {
+        return useBytesMessage;
+    }
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSDefaultProcessor.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSDefaultProcessor.java
new file mode 100644
index 0000000000..6b5488a168
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSDefaultProcessor.java
@@ -0,0 +1,89 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms.wireformat;
+
+import javax.xml.namespace.QName;
+import javax.xml.stream.XMLStreamException;
+import javax.xml.stream.XMLStreamReader;
+import javax.xml.stream.XMLStreamWriter;
+
+import org.apache.tuscany.sca.assembly.xml.Constants;
+import org.apache.tuscany.sca.contribution.processor.BaseStAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.processor.ContributionReadException;
+import org.apache.tuscany.sca.contribution.processor.ContributionResolveException;
+import org.apache.tuscany.sca.contribution.processor.ContributionWriteException;
+import org.apache.tuscany.sca.contribution.processor.ProcessorContext;
+import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.resolver.ModelResolver;
+import org.apache.tuscany.sca.core.FactoryExtensionPoint;
+
+/**
+ * 
+ * @version $Rev$ $Date$
+ */
+public class WireFormatJMSDefaultProcessor extends BaseStAXArtifactProcessor implements StAXArtifactProcessor<WireFormatJMSDefault> {
+
+    public QName getArtifactType() {
+        return WireFormatJMSDefault.WIRE_FORMAT_JMS_DEFAULT_QNAME;
+    }
+
+    public WireFormatJMSDefaultProcessor(FactoryExtensionPoint modelFactories) {
+    }
+
+    public WireFormatJMSDefault read(XMLStreamReader reader, ProcessorContext context) throws ContributionReadException, XMLStreamException {
+        WireFormatJMSDefault wireFormat = new WireFormatJMSDefault();
+
+        String sendFormat = reader.getAttributeValue(null, WireFormatJMSDefault.WIRE_FORMAT_JMS_DEFAULT_FORMAT_ATTR);
+        if (sendFormat != null && sendFormat.length() > 0) {
+            if (WireFormatJMSDefault.WIRE_FORMAT_JMS_DEFAULT_TEXT_FORMAT_VAL.equalsIgnoreCase(sendFormat)) {
+                wireFormat.setUseBytesMessage(false);
+            }else if (WireFormatJMSDefault.WIRE_FORMAT_JMS_DEFAULT_BYTES_FORMAT_VAL.equalsIgnoreCase(sendFormat)) {
+                wireFormat.setUseBytesMessage(true);
+            }else{
+                throw new ContributionReadException(WireFormatJMSDefault.WIRE_FORMAT_JMS_DEFAULT_QNAME.toString() +" " +sendFormat + " is not a valid attribute value for " + 
+                        WireFormatJMSDefault.WIRE_FORMAT_JMS_DEFAULT_FORMAT_ATTR);
+            }
+        }
+
+        return wireFormat;
+    }
+
+    public void write(WireFormatJMSDefault wireFormat, XMLStreamWriter writer, ProcessorContext context) throws ContributionWriteException, XMLStreamException {
+        String prefix = "tuscany";
+        writer.writeStartElement(prefix, getArtifactType().getLocalPart(), getArtifactType().getNamespaceURI());
+        writer.writeNamespace("tuscany", Constants.SCA11_TUSCANY_NS);
+        
+        if (wireFormat.isUseBytesMessage()) {
+            writer.writeAttribute(WireFormatJMSDefault.WIRE_FORMAT_JMS_DEFAULT_FORMAT_ATTR, WireFormatJMSDefault.WIRE_FORMAT_JMS_DEFAULT_BYTES_FORMAT_VAL);
+        } else {
+            writer.writeAttribute(WireFormatJMSDefault.WIRE_FORMAT_JMS_DEFAULT_FORMAT_ATTR, WireFormatJMSDefault.WIRE_FORMAT_JMS_DEFAULT_TEXT_FORMAT_VAL);
+        }
+
+        writer.writeEndElement();
+    }
+
+    public Class<WireFormatJMSDefault> getModelType() {
+        return WireFormatJMSDefault.class;
+    }
+
+    public void resolve(WireFormatJMSDefault arg0, ModelResolver arg1, ProcessorContext context) throws ContributionResolveException {
+
+    }
+
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSObject.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSObject.java
new file mode 100644
index 0000000000..e043139010
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSObject.java
@@ -0,0 +1,57 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms.wireformat;
+
+import javax.xml.namespace.QName;
+
+import org.apache.tuscany.sca.assembly.WireFormat;
+import org.apache.tuscany.sca.assembly.xml.Constants;
+
+/**
+ * Implementation for policies that could be injected as parameter
+ * into the axis2config.
+ *
+ * @version $Rev$ $Date$
+ */
+public class WireFormatJMSObject implements WireFormat {
+    public static final QName WIRE_FORMAT_JMS_BYTES_QNAME = new QName(Constants.SCA11_TUSCANY_NS, "wireFormat.jmsObject");
+    
+    public static final String WIRE_FORMAT_JMS_OBJECT_WRAP_SINGLE_ATTR = "wrapSingle";
+    
+    private boolean wrappedSingleInput = false;
+    
+    public QName getSchemaName() {
+        return WIRE_FORMAT_JMS_BYTES_QNAME;
+    }
+
+    public boolean isUnresolved() {
+        return false;
+    }
+
+    public void setUnresolved(boolean unresolved) {
+    }
+
+    public void setWrappedSingleInput(boolean wrappedSingleInput) {
+        this.wrappedSingleInput = wrappedSingleInput;
+    }
+
+    public boolean isWrappedSingleInput() {
+        return wrappedSingleInput;
+    }
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSObjectProcessor.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSObjectProcessor.java
new file mode 100644
index 0000000000..cf0c0db0d7
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSObjectProcessor.java
@@ -0,0 +1,88 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms.wireformat;
+
+import javax.xml.namespace.QName;
+import javax.xml.stream.XMLStreamException;
+import javax.xml.stream.XMLStreamReader;
+import javax.xml.stream.XMLStreamWriter;
+
+import org.apache.tuscany.sca.assembly.xml.Constants;
+import org.apache.tuscany.sca.contribution.processor.BaseStAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.processor.ContributionReadException;
+import org.apache.tuscany.sca.contribution.processor.ContributionResolveException;
+import org.apache.tuscany.sca.contribution.processor.ContributionWriteException;
+import org.apache.tuscany.sca.contribution.processor.ProcessorContext;
+import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.resolver.ModelResolver;
+import org.apache.tuscany.sca.core.FactoryExtensionPoint;
+
+/**
+ *
+ * @version $Rev$ $Date$
+ */
+public class WireFormatJMSObjectProcessor extends BaseStAXArtifactProcessor implements StAXArtifactProcessor<WireFormatJMSObject> {
+    
+    public QName getArtifactType() {
+        return WireFormatJMSObject.WIRE_FORMAT_JMS_BYTES_QNAME;
+    }
+    
+    public WireFormatJMSObjectProcessor(FactoryExtensionPoint modelFactories) {
+    }
+
+    
+    public WireFormatJMSObject read(XMLStreamReader reader, ProcessorContext context) throws ContributionReadException, XMLStreamException {
+        WireFormatJMSObject wireFormat = new WireFormatJMSObject();
+        
+        String wrappedSingleInput = reader.getAttributeValue(null, WireFormatJMSObject.WIRE_FORMAT_JMS_OBJECT_WRAP_SINGLE_ATTR);
+        if (wrappedSingleInput != null && wrappedSingleInput.length() > 0) {
+            if ("true".equalsIgnoreCase(wrappedSingleInput)) {
+                wireFormat.setWrappedSingleInput(true);
+            } else if ("false".equalsIgnoreCase(wrappedSingleInput)) {
+                wireFormat.setWrappedSingleInput(false);
+            } else {
+                throw new ContributionReadException(WireFormatJMSObject.WIRE_FORMAT_JMS_BYTES_QNAME.toString() + ": " + wrappedSingleInput + 
+                        " is not a valid attribute value for " + WireFormatJMSObject.WIRE_FORMAT_JMS_OBJECT_WRAP_SINGLE_ATTR);
+            }
+        }
+        return wireFormat;
+    }
+
+    public void write(WireFormatJMSObject wireFormat, XMLStreamWriter writer, ProcessorContext context) 
+        throws ContributionWriteException, XMLStreamException {
+        String prefix = "tuscany";
+        writer.writeStartElement(prefix, 
+                                 getArtifactType().getLocalPart(),
+                                 getArtifactType().getNamespaceURI());
+        writer.writeNamespace("tuscany", Constants.SCA11_TUSCANY_NS); 
+        
+        writer.writeAttribute(WireFormatJMSObject.WIRE_FORMAT_JMS_OBJECT_WRAP_SINGLE_ATTR, String.valueOf(wireFormat.isWrappedSingleInput()));
+        
+        writer.writeEndElement();
+    }
+
+    public Class<WireFormatJMSObject> getModelType() {
+        return WireFormatJMSObject.class;
+    }
+
+    public void resolve(WireFormatJMSObject arg0, ModelResolver arg1, ProcessorContext context) throws ContributionResolveException {
+
+    }
+    
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSText.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSText.java
new file mode 100644
index 0000000000..4f728cea92
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSText.java
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms.wireformat;
+
+import javax.xml.namespace.QName;
+
+import org.apache.tuscany.sca.assembly.WireFormat;
+import org.apache.tuscany.sca.assembly.xml.Constants;
+
+/**
+ * Implementation for policies that could be injected as parameter
+ * into the axis2config.
+ *
+ * @version $Rev$ $Date$
+ */
+public class WireFormatJMSText implements WireFormat {
+    public static final QName WIRE_FORMAT_JMS_BYTES_QNAME = new QName(Constants.SCA11_TUSCANY_NS, "wireFormat.jmsText");
+    
+    public QName getSchemaName() {
+        return WIRE_FORMAT_JMS_BYTES_QNAME;
+    }
+
+    public boolean isUnresolved() {
+        return false;
+    }
+
+    public void setUnresolved(boolean unresolved) {
+    }
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSTextProcessor.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSTextProcessor.java
new file mode 100644
index 0000000000..5c564e044c
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSTextProcessor.java
@@ -0,0 +1,75 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms.wireformat;
+
+import javax.xml.namespace.QName;
+import javax.xml.stream.XMLStreamException;
+import javax.xml.stream.XMLStreamReader;
+import javax.xml.stream.XMLStreamWriter;
+
+import org.apache.tuscany.sca.assembly.xml.Constants;
+import org.apache.tuscany.sca.contribution.processor.BaseStAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.processor.ContributionReadException;
+import org.apache.tuscany.sca.contribution.processor.ContributionResolveException;
+import org.apache.tuscany.sca.contribution.processor.ContributionWriteException;
+import org.apache.tuscany.sca.contribution.processor.ProcessorContext;
+import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.resolver.ModelResolver;
+import org.apache.tuscany.sca.core.FactoryExtensionPoint;
+
+/**
+ *
+ * @version $Rev$ $Date$
+ */
+public class WireFormatJMSTextProcessor extends BaseStAXArtifactProcessor implements StAXArtifactProcessor<WireFormatJMSText> {
+    
+    public QName getArtifactType() {
+        return WireFormatJMSText.WIRE_FORMAT_JMS_BYTES_QNAME;
+    }
+    
+    public WireFormatJMSTextProcessor(FactoryExtensionPoint modelFactories) {
+    }
+
+    
+    public WireFormatJMSText read(XMLStreamReader reader, ProcessorContext context) throws ContributionReadException, XMLStreamException {
+        WireFormatJMSText wireFormat = new WireFormatJMSText();
+         
+        return wireFormat;
+    }
+
+    public void write(WireFormatJMSText wireFormat, XMLStreamWriter writer, ProcessorContext context) 
+        throws ContributionWriteException, XMLStreamException {
+        String prefix = "tuscany";
+        writer.writeStartElement(prefix, 
+                                 getArtifactType().getLocalPart(),
+                                 getArtifactType().getNamespaceURI());
+        writer.writeNamespace("tuscany", Constants.SCA11_TUSCANY_NS); 
+        
+        writer.writeEndElement();
+    }
+
+    public Class<WireFormatJMSText> getModelType() {
+        return WireFormatJMSText.class;
+    }
+
+    public void resolve(WireFormatJMSText arg0, ModelResolver arg1, ProcessorContext context) throws ContributionResolveException {
+
+    }
+    
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSTextXML.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSTextXML.java
new file mode 100644
index 0000000000..be6187d2c5
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSTextXML.java
@@ -0,0 +1,48 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms.wireformat;
+
+import javax.xml.namespace.QName;
+
+import org.apache.tuscany.sca.assembly.WireFormat;
+import org.apache.tuscany.sca.assembly.xml.Constants;
+
+/**
+ *
+ * @version $Rev$ $Date$
+ */
+public class WireFormatJMSTextXML implements WireFormat {
+    public static final QName WIRE_FORMAT_JMS_DEFAULT_QNAME = new QName(Constants.SCA11_TUSCANY_NS, "wireFormat.jmsTextXML");
+    
+    public QName getSchemaName() {
+        return WIRE_FORMAT_JMS_DEFAULT_QNAME;
+    }
+
+    public boolean isUnresolved() {
+        return false;
+    }
+
+    public void setUnresolved(boolean unresolved) {
+    }
+    
+    @Override
+    public boolean equals(Object obj) {
+        return this.getClass() == obj.getClass();
+    }
+}
diff --git a/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSTextXMLProcessor.java b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSTextXMLProcessor.java
new file mode 100644
index 0000000000..ae544f3163
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSTextXMLProcessor.java
@@ -0,0 +1,75 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.binding.jms.wireformat;
+
+import javax.xml.namespace.QName;
+import javax.xml.stream.XMLStreamException;
+import javax.xml.stream.XMLStreamReader;
+import javax.xml.stream.XMLStreamWriter;
+
+import org.apache.tuscany.sca.assembly.xml.Constants;
+import org.apache.tuscany.sca.contribution.processor.BaseStAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.processor.ContributionReadException;
+import org.apache.tuscany.sca.contribution.processor.ContributionResolveException;
+import org.apache.tuscany.sca.contribution.processor.ContributionWriteException;
+import org.apache.tuscany.sca.contribution.processor.ProcessorContext;
+import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.resolver.ModelResolver;
+import org.apache.tuscany.sca.core.FactoryExtensionPoint;
+
+/**
+ *
+ * @version $Rev$ $Date$
+ */
+public class WireFormatJMSTextXMLProcessor extends BaseStAXArtifactProcessor implements StAXArtifactProcessor<WireFormatJMSTextXML> {
+    
+    public QName getArtifactType() {
+        return WireFormatJMSTextXML.WIRE_FORMAT_JMS_DEFAULT_QNAME;
+    }
+    
+    public WireFormatJMSTextXMLProcessor(FactoryExtensionPoint modelFactories) {
+    }
+
+    
+    public WireFormatJMSTextXML read(XMLStreamReader reader, ProcessorContext context) throws ContributionReadException, XMLStreamException {
+        WireFormatJMSTextXML wireFormat = new WireFormatJMSTextXML();
+         
+        return wireFormat;
+    }
+
+    public void write(WireFormatJMSTextXML wireFormat, XMLStreamWriter writer, ProcessorContext context) 
+        throws ContributionWriteException, XMLStreamException {
+        String prefix = "tuscany";
+        writer.writeStartElement(prefix, 
+                                 getArtifactType().getLocalPart(),
+                                 getArtifactType().getNamespaceURI());
+        writer.writeNamespace("tuscany", Constants.SCA11_TUSCANY_NS); 
+        
+        writer.writeEndElement();
+    }
+
+    public Class<WireFormatJMSTextXML> getModelType() {
+        return WireFormatJMSTextXML.class;
+    }
+
+    public void resolve(WireFormatJMSTextXML arg0, ModelResolver arg1, ProcessorContext context) throws ContributionResolveException {
+
+    }
+    
+}