addressingfaultshelper.java

来自「开源的axis2框架的源码。用于开发WEBSERVER」· Java 代码 · 共 412 行 · 第 1/2 页

/*
 * 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.axis2.addressing;

import org.apache.axiom.om.OMAbstractFactory;
import org.apache.axiom.om.OMElement;
import org.apache.axiom.om.OMNamespace;
import org.apache.axiom.soap.SOAP12Constants;
import org.apache.axiom.soap.SOAPFactory;
import org.apache.axiom.soap.SOAPFaultCode;
import org.apache.axiom.soap.SOAPFaultSubCode;
import org.apache.axiom.soap.SOAPFaultValue;
import org.apache.axis2.AxisFault;
import org.apache.axis2.Constants;
import org.apache.axis2.addressing.AddressingConstants.Final;
import org.apache.axis2.addressing.AddressingConstants.Submission;
import org.apache.axis2.addressing.i18n.AddressingMessages;
import org.apache.axis2.context.MessageContext;
import org.apache.axis2.context.OperationContext;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import javax.xml.namespace.QName;
import java.util.HashMap;
import java.util.Map;

public class AddressingFaultsHelper {

    private static final Log log = LogFactory.getLog(AddressingFaultsHelper.class);

    /**
     * Build an understanndable fault string for the given faultCode and wsa:FaultDetail info.
     * Should really use a message bundle.
     *
     * @param faultCodeLocalName
     * @param faultDetail
     * @return
     */
    public static String getMessageForAxisFault(String faultCodeLocalName, String faultDetail) {
        String result = null;

        if (Submission.FAULT_INVALID_HEADER.equals(faultCodeLocalName)) {
            if (faultDetail != null) {
                result = AddressingMessages
                        .getMessage("specificInvalidAddressingHeader", faultDetail);
            } else {
                result = AddressingMessages.getMessage("invalidAddressingHeader");
            }
        } else if (Final.FAULT_INVALID_HEADER.equals(faultCodeLocalName)) {
            if (faultDetail != null) {
                result = AddressingMessages
                        .getMessage("specificInvalidAddressingHeader", faultDetail);
            } else {
                result = AddressingMessages.getMessage("invalidAddressingHeader");
            }
        } else if ("InvalidCardinality".equals(faultCodeLocalName)) {
            if (faultDetail != null) {
                result = AddressingMessages.getMessage("specificInvalidCardinality", faultDetail);
            } else {
                result = AddressingMessages.getMessage("invalidCardinality");
            }
        } else if ("MissingAddressInEPR".equals(faultCodeLocalName)) {
            if (faultDetail != null) {
                result = AddressingMessages.getMessage("specificMissingAddressInEPR", faultDetail);
            } else {
                result = AddressingMessages.getMessage("missingAddressInEPR");
            }
        } else if ("DuplicateMessageID".equals(faultCodeLocalName)) {
            result = AddressingMessages.getMessage("duplicateMessageID");
        } else if ("ActionMismatch".equals(faultCodeLocalName)) {
            result = AddressingMessages.getMessage("actionMismatch");
        } else if (Final.FAULT_ONLY_ANONYMOUS_ADDRESS_SUPPORTED.equals(faultCodeLocalName)) {
            if (faultDetail != null) {
                result = AddressingMessages
                        .getMessage("specificOnlyAnonymousSupported", faultDetail);
            } else {
                result = AddressingMessages.getMessage("onlyAnonymousSupported");
            }
        } else if (Final.FAULT_ONLY_NON_ANONYMOUS_ADDRESS_SUPPORTED.equals(faultCodeLocalName)) {
            if (faultDetail != null) {
                result = AddressingMessages.getMessage("specificOnlyNonAnonSupported", faultDetail);
            } else {
                result = AddressingMessages.getMessage("onlyNonAnonSupported");
            }
        } else if (Submission.FAULT_ADDRESSING_HEADER_REQUIRED.equals(faultCodeLocalName)) {
            if (faultDetail != null) {
                result = AddressingMessages
                        .getMessage("specificAddressingHeaderRequired", faultDetail);
            } else {
                result = AddressingMessages.getMessage("addressingHeaderRequired");
            }
        } else if (Final.FAULT_ADDRESSING_HEADER_REQUIRED.equals(faultCodeLocalName)) {
            if (faultDetail != null) {
                result = AddressingMessages
                        .getMessage("specificAddressingHeaderRequired", faultDetail);
            } else {
                result = AddressingMessages.getMessage("addressingHeaderRequired");
            }
        } else
        if (AddressingConstants.FAULT_ADDRESSING_DESTINATION_UNREACHABLE.equals(faultCodeLocalName))
        {
            if (faultDetail != null) {
                result = AddressingMessages
                        .getMessage("specificDestinationUnreachable", faultDetail);
            } else {
                result = AddressingMessages.getMessage("destinationUnreachable");
            }
        } else if (AddressingConstants.FAULT_ACTION_NOT_SUPPORTED.equals(faultCodeLocalName)) {
            if (faultDetail != null) {
                result = AddressingMessages.getMessage("specificActionNotRecognised", faultDetail);
            } else {
                result = AddressingMessages.getMessage("actionNotRecognised");
            }
        }

        return result;
    }

    //    wsa:InvalidAddressingHeader [Reason] the string: "A header representing a Message Addressing Property is not valid and the message cannot be processed"
    //      wsa:InvalidAddress
    //      wsa:InvalidEPR
    //      wsa:InvalidCardinality
    public static void triggerInvalidCardinalityFault(MessageContext messageContext,
                                                      String incorrectHeaderName) throws AxisFault {
        if (log.isDebugEnabled()) {
            log.debug("triggerInvalidCardinalityFault: messageContext: " + messageContext +
                    " incorrectHeaderName: " + incorrectHeaderName);
        }
        String namespace =
                (String)messageContext.getProperty(AddressingConstants.WS_ADDRESSING_VERSION);
        if (Submission.WSA_NAMESPACE.equals(namespace)) {
            triggerAddressingFault(messageContext, Final.FAULT_HEADER_PROB_HEADER_QNAME,
                                   AddressingConstants.WSA_DEFAULT_PREFIX + ":" +
                                           incorrectHeaderName, Submission.FAULT_INVALID_HEADER,
                                                                null, AddressingMessages.getMessage(
                    "spec.submission.FAULT_INVALID_HEADER_REASON"));
        } else {
            triggerAddressingFault(messageContext, Final.FAULT_HEADER_PROB_HEADER_QNAME,
                                   AddressingConstants.WSA_DEFAULT_PREFIX + ":" +
                                           incorrectHeaderName, Final.FAULT_INVALID_HEADER,
                                                                "InvalidCardinality",
                                                                AddressingMessages.getMessage(
                                                                        "spec.final.FAULT_INVALID_HEADER_REASON"));
        }
    }

    //      wsa:MissingAddressInEPR
    public static void triggerMissingAddressInEPRFault(MessageContext messageContext,
                                                       String incorrectHeaderName)
            throws AxisFault {
        if (log.isDebugEnabled()) {
            log.debug("triggerMissingAddressInEPRFault: messageContext: " + messageContext +
                    " incorrectHeaderName: " + incorrectHeaderName);
        }
        String namespace =
                (String)messageContext.getProperty(AddressingConstants.WS_ADDRESSING_VERSION);
        if (Submission.WSA_NAMESPACE.equals(namespace)) {
            triggerAddressingFault(messageContext, Final.FAULT_HEADER_PROB_HEADER_QNAME,
                                   AddressingConstants.WSA_DEFAULT_PREFIX + ":" +
                                           incorrectHeaderName, Submission.FAULT_INVALID_HEADER,
                                                                null, AddressingMessages.getMessage(
                    "spec.submission.FAULT_INVALID_HEADER_REASON"));
        } else {
            triggerAddressingFault(messageContext, Final.FAULT_HEADER_PROB_HEADER_QNAME,
                                   AddressingConstants.WSA_DEFAULT_PREFIX + ":" +
                                           incorrectHeaderName, Final.FAULT_INVALID_HEADER,
                                                                "MissingAddressInEPR",
                                                                AddressingMessages.getMessage(
                                                                        "spec.final.FAULT_INVALID_HEADER_REASON"));
        }
    }

    //      wsa:DuplicateMessageID
    //      wsa:ActionMismatch
    public static void triggerActionMismatchFault(MessageContext messageContext) throws AxisFault {
        if (log.isDebugEnabled()) {
            log.debug("triggerActionMismatchFault: messageContext: " + messageContext);
        }
        String namespace =
                (String)messageContext.getProperty(AddressingConstants.WS_ADDRESSING_VERSION);
        if (Submission.WSA_NAMESPACE.equals(namespace)) {
            triggerAddressingFault(messageContext, Final.FAULT_HEADER_PROB_HEADER_QNAME,
                                   AddressingConstants.WSA_DEFAULT_PREFIX + ":Action",
                                   Submission.FAULT_INVALID_HEADER, null,
                                   AddressingMessages.getMessage(
                                           "spec.submission.FAULT_INVALID_HEADER_REASON"));
        } else {
            triggerAddressingFault(messageContext, Final.FAULT_HEADER_PROB_HEADER_QNAME,
                                   AddressingConstants.WSA_DEFAULT_PREFIX + ":Action",
                                   Final.FAULT_INVALID_HEADER, "ActionMismatch",