diff options
Diffstat (limited to 'java/sca/modules/binding-jms/src/main/java/org')
25 files changed, 0 insertions, 4246 deletions
diff --git a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/BindingProperty.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/BindingProperty.java deleted file mode 100644 index c195a16ce5..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/BindingProperty.java +++ /dev/null @@ -1,71 +0,0 @@ -/*
- * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBinding.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBinding.java deleted file mode 100644 index 8e6684b44d..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBinding.java +++ /dev/null @@ -1,974 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBindingConstants.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBindingConstants.java deleted file mode 100644 index 80bc61baa1..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBindingConstants.java +++ /dev/null @@ -1,75 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBindingException.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBindingException.java deleted file mode 100644 index 74f030ca21..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBindingException.java +++ /dev/null @@ -1,45 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBindingProcessor.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBindingProcessor.java deleted file mode 100644 index be5673bc60..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/JMSBindingProcessor.java +++ /dev/null @@ -1,1541 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSDefault.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSDefault.java deleted file mode 100644 index a02decd20f..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSDefault.java +++ /dev/null @@ -1,45 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSDefaultProcessor.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSDefaultProcessor.java deleted file mode 100644 index 4f09eeb9a5..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSDefaultProcessor.java +++ /dev/null @@ -1,76 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSUserProp.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSUserProp.java deleted file mode 100644 index f978adfa58..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSUserProp.java +++ /dev/null @@ -1,57 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSUserPropProcessor.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSUserPropProcessor.java deleted file mode 100644 index 9b731ffb1b..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/operationselector/OperationSelectorJMSUserPropProcessor.java +++ /dev/null @@ -1,87 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/authentication/token/JMSTokenAuthenticationPolicy.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/authentication/token/JMSTokenAuthenticationPolicy.java deleted file mode 100644 index 24f43d3027..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/authentication/token/JMSTokenAuthenticationPolicy.java +++ /dev/null @@ -1,55 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/authentication/token/JMSTokenAuthenticationPolicyProcessor.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/authentication/token/JMSTokenAuthenticationPolicyProcessor.java deleted file mode 100644 index 4322595515..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/authentication/token/JMSTokenAuthenticationPolicyProcessor.java +++ /dev/null @@ -1,111 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/header/JMSHeaderPolicy.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/header/JMSHeaderPolicy.java deleted file mode 100644 index 48fef397c7..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/header/JMSHeaderPolicy.java +++ /dev/null @@ -1,130 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/header/JMSHeaderPolicyProcessor.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/header/JMSHeaderPolicyProcessor.java deleted file mode 100644 index c925c01554..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/policy/header/JMSHeaderPolicyProcessor.java +++ /dev/null @@ -1,206 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytes.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytes.java deleted file mode 100644 index a16cdc9c4f..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytes.java +++ /dev/null @@ -1,45 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytesProcessor.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytesProcessor.java deleted file mode 100644 index 8be904da3e..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytesProcessor.java +++ /dev/null @@ -1,75 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytesXML.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytesXML.java deleted file mode 100644 index 4f7a91657f..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytesXML.java +++ /dev/null @@ -1,40 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytesXMLProcessor.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytesXMLProcessor.java deleted file mode 100644 index 33533b23eb..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSBytesXMLProcessor.java +++ /dev/null @@ -1,72 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSDefault.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSDefault.java deleted file mode 100644 index 5c33a3e2c8..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSDefault.java +++ /dev/null @@ -1,64 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSDefaultProcessor.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSDefaultProcessor.java deleted file mode 100644 index 6b5488a168..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSDefaultProcessor.java +++ /dev/null @@ -1,89 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSObject.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSObject.java deleted file mode 100644 index e043139010..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSObject.java +++ /dev/null @@ -1,57 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSObjectProcessor.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSObjectProcessor.java deleted file mode 100644 index cf0c0db0d7..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSObjectProcessor.java +++ /dev/null @@ -1,88 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSText.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSText.java deleted file mode 100644 index 4f728cea92..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSText.java +++ /dev/null @@ -1,45 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSTextProcessor.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSTextProcessor.java deleted file mode 100644 index 5c564e044c..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSTextProcessor.java +++ /dev/null @@ -1,75 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSTextXML.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSTextXML.java deleted file mode 100644 index be6187d2c5..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSTextXML.java +++ /dev/null @@ -1,48 +0,0 @@ -/* - * 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/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSTextXMLProcessor.java b/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSTextXMLProcessor.java deleted file mode 100644 index ae544f3163..0000000000 --- a/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/wireformat/WireFormatJMSTextXMLProcessor.java +++ /dev/null @@ -1,75 +0,0 @@ -/* - * 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 { - - } - -} |