src/share/jaxws_classes/com/sun/xml/internal/ws/addressing/policy/AddressingFeatureConfigurator.java

Thu, 31 Aug 2017 15:18:52 +0800

author
aoqi
date
Thu, 31 Aug 2017 15:18:52 +0800
changeset 637
9c07ef4934dd
parent 368
0989ad8c0860
parent 0
373ffda63c9a
permissions
-rw-r--r--

merge

aoqi@0 1 /*
aoqi@0 2 * Copyright (c) 1997, 2012, Oracle and/or its affiliates. All rights reserved.
aoqi@0 3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
aoqi@0 4 *
aoqi@0 5 * This code is free software; you can redistribute it and/or modify it
aoqi@0 6 * under the terms of the GNU General Public License version 2 only, as
aoqi@0 7 * published by the Free Software Foundation. Oracle designates this
aoqi@0 8 * particular file as subject to the "Classpath" exception as provided
aoqi@0 9 * by Oracle in the LICENSE file that accompanied this code.
aoqi@0 10 *
aoqi@0 11 * This code is distributed in the hope that it will be useful, but WITHOUT
aoqi@0 12 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
aoqi@0 13 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
aoqi@0 14 * version 2 for more details (a copy is included in the LICENSE file that
aoqi@0 15 * accompanied this code).
aoqi@0 16 *
aoqi@0 17 * You should have received a copy of the GNU General Public License version
aoqi@0 18 * 2 along with this work; if not, write to the Free Software Foundation,
aoqi@0 19 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
aoqi@0 20 *
aoqi@0 21 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
aoqi@0 22 * or visit www.oracle.com if you need additional information or have any
aoqi@0 23 * questions.
aoqi@0 24 */
aoqi@0 25
aoqi@0 26 package com.sun.xml.internal.ws.addressing.policy;
aoqi@0 27
aoqi@0 28 import com.sun.xml.internal.ws.api.addressing.AddressingVersion;
aoqi@0 29 import com.sun.xml.internal.ws.policy.AssertionSet;
aoqi@0 30 import com.sun.xml.internal.ws.policy.NestedPolicy;
aoqi@0 31 import com.sun.xml.internal.ws.policy.Policy;
aoqi@0 32 import com.sun.xml.internal.ws.policy.PolicyAssertion;
aoqi@0 33 import com.sun.xml.internal.ws.policy.PolicyException;
aoqi@0 34 import com.sun.xml.internal.ws.policy.PolicyMap;
aoqi@0 35 import com.sun.xml.internal.ws.policy.PolicyMapKey;
aoqi@0 36 import com.sun.xml.internal.ws.policy.jaxws.spi.PolicyFeatureConfigurator;
aoqi@0 37 import com.sun.xml.internal.ws.policy.privateutil.PolicyLogger;
aoqi@0 38 import com.sun.xml.internal.ws.addressing.W3CAddressingMetadataConstants;
aoqi@0 39 import com.sun.xml.internal.ws.resources.ModelerMessages;
aoqi@0 40 import com.sun.xml.internal.bind.util.Which;
aoqi@0 41
aoqi@0 42 import java.util.Collection;
aoqi@0 43 import java.util.Iterator;
aoqi@0 44 import java.util.LinkedList;
aoqi@0 45 import java.util.logging.Level;
aoqi@0 46 import javax.xml.namespace.QName;
aoqi@0 47 import javax.xml.ws.WebServiceFeature;
aoqi@0 48 import javax.xml.ws.WebServiceException;
aoqi@0 49 import javax.xml.ws.soap.AddressingFeature;
aoqi@0 50
aoqi@0 51 /**
aoqi@0 52 * This Policy extension configures the WSDLModel with AddressingFeature when Addressing assertions are present in the
aoqi@0 53 * PolicyMap.
aoqi@0 54 *
aoqi@0 55 * @author japod
aoqi@0 56 * @author Rama Pulavarthi
aoqi@0 57 */
aoqi@0 58 public class AddressingFeatureConfigurator implements PolicyFeatureConfigurator {
aoqi@0 59
aoqi@0 60 private static final PolicyLogger LOGGER = PolicyLogger.getLogger(AddressingFeatureConfigurator.class);
aoqi@0 61
aoqi@0 62 private static final QName[] ADDRESSING_ASSERTIONS = {
aoqi@0 63 new QName(AddressingVersion.MEMBER.policyNsUri, "UsingAddressing")};
aoqi@0 64
aoqi@0 65 /**
aoqi@0 66 * Creates a new instance of AddressingFeatureConfigurator
aoqi@0 67 */
aoqi@0 68 public AddressingFeatureConfigurator() {
aoqi@0 69 }
aoqi@0 70
aoqi@0 71 public Collection<WebServiceFeature> getFeatures(final PolicyMapKey key, final PolicyMap policyMap) throws PolicyException {
aoqi@0 72 LOGGER.entering(key, policyMap);
aoqi@0 73 final Collection<WebServiceFeature> features = new LinkedList<WebServiceFeature>();
aoqi@0 74 if ((key != null) && (policyMap != null)) {
aoqi@0 75 final Policy policy = policyMap.getEndpointEffectivePolicy(key);
aoqi@0 76 for (QName addressingAssertionQName : ADDRESSING_ASSERTIONS) {
aoqi@0 77 if ((policy != null) && policy.contains(addressingAssertionQName)) {
aoqi@0 78 final Iterator <AssertionSet> assertions = policy.iterator();
aoqi@0 79 while(assertions.hasNext()){
aoqi@0 80 final AssertionSet assertionSet = assertions.next();
aoqi@0 81 final Iterator<PolicyAssertion> policyAssertion = assertionSet.iterator();
aoqi@0 82 while(policyAssertion.hasNext()){
aoqi@0 83 final PolicyAssertion assertion = policyAssertion.next();
aoqi@0 84 if(assertion.getName().equals(addressingAssertionQName)){
aoqi@0 85 final WebServiceFeature feature = AddressingVersion.getFeature(addressingAssertionQName.getNamespaceURI(), true, !assertion.isOptional());
aoqi@0 86 if (LOGGER.isLoggable(Level.FINE)) {
aoqi@0 87 LOGGER.fine("Added addressing feature \"" + feature + "\" for element \"" + key + "\"");
aoqi@0 88 }
aoqi@0 89 features.add(feature);
aoqi@0 90 } // end-if non optional wsa assertion found
aoqi@0 91 } // next assertion
aoqi@0 92 } // next alternative
aoqi@0 93 } // end-if policy contains wsa assertion
aoqi@0 94 } //end foreach addr assertion
aoqi@0 95
aoqi@0 96 // Deal with WS-Addressing 1.0 Metadata assertions
aoqi@0 97 if (policy != null && policy.contains(W3CAddressingMetadataConstants.WSAM_ADDRESSING_ASSERTION)) {
aoqi@0 98 for (AssertionSet assertions : policy) {
aoqi@0 99 for (PolicyAssertion assertion : assertions) {
aoqi@0 100 if (assertion.getName().equals(W3CAddressingMetadataConstants.WSAM_ADDRESSING_ASSERTION)) {
aoqi@0 101 NestedPolicy nestedPolicy = assertion.getNestedPolicy();
aoqi@0 102 boolean requiresAnonymousResponses = false;
aoqi@0 103 boolean requiresNonAnonymousResponses = false;
aoqi@0 104 if (nestedPolicy != null) {
aoqi@0 105 requiresAnonymousResponses = nestedPolicy.contains(W3CAddressingMetadataConstants.WSAM_ANONYMOUS_NESTED_ASSERTION);
aoqi@0 106 requiresNonAnonymousResponses = nestedPolicy.contains(W3CAddressingMetadataConstants.WSAM_NONANONYMOUS_NESTED_ASSERTION);
aoqi@0 107 }
aoqi@0 108 if(requiresAnonymousResponses && requiresNonAnonymousResponses) {
aoqi@0 109 throw new WebServiceException("Only one among AnonymousResponses and NonAnonymousResponses can be nested in an Addressing assertion");
aoqi@0 110 }
aoqi@0 111
aoqi@0 112 final WebServiceFeature feature;
aoqi@0 113 try {
aoqi@0 114 if (requiresAnonymousResponses) {
aoqi@0 115 feature = new AddressingFeature(true, !assertion.isOptional(), AddressingFeature.Responses.ANONYMOUS);
aoqi@0 116 } else if (requiresNonAnonymousResponses) {
aoqi@0 117 feature = new AddressingFeature(true, !assertion.isOptional(), AddressingFeature.Responses.NON_ANONYMOUS);
aoqi@0 118 } else {
aoqi@0 119 feature = new AddressingFeature(true, !assertion.isOptional());
aoqi@0 120 }
aoqi@0 121 } catch (NoSuchMethodError e) {
aoqi@0 122 throw LOGGER.logSevereException(new PolicyException(ModelerMessages.RUNTIME_MODELER_ADDRESSING_RESPONSES_NOSUCHMETHOD(toJar(Which.which(AddressingFeature.class))), e));
aoqi@0 123 }
aoqi@0 124 if (LOGGER.isLoggable(Level.FINE)) {
aoqi@0 125 LOGGER.fine("Added addressing feature \"" + feature + "\" for element \"" + key + "\"");
aoqi@0 126 }
aoqi@0 127 features.add(feature);
aoqi@0 128 }
aoqi@0 129 }
aoqi@0 130 }
aoqi@0 131 }
aoqi@0 132 }
aoqi@0 133 LOGGER.exiting(features);
aoqi@0 134 return features;
aoqi@0 135 }
aoqi@0 136
aoqi@0 137 /**
aoqi@0 138 * Given the URL String inside jar, returns the URL to the jar itself.
aoqi@0 139 */
aoqi@0 140 private static String toJar(String url) {
aoqi@0 141 if(!url.startsWith("jar:"))
aoqi@0 142 return url;
aoqi@0 143 url = url.substring(4); // cut off jar:
aoqi@0 144 return url.substring(0,url.lastIndexOf('!')); // cut off everything after '!'
aoqi@0 145 }
aoqi@0 146 }

mercurial