import com.sun.xml.internal.ws.resources.AddressingMessages; //导入依赖的package包/类
public static WSEndpointReference getFaultTo(@NotNull MessageHeaders headers, @NotNull AddressingVersion av, @NotNull SOAPVersion sv) {
    if (av == null) {
        throw new IllegalArgumentException(AddressingMessages.NULL_ADDRESSING_VERSION());
    }

    Header h = getFirstHeader(headers, av.faultToTag, true, sv);
    WSEndpointReference faultTo = null;
    if (h != null) {
        try {
            faultTo = h.readAsEPR(av);
        } catch (XMLStreamException e) {
            throw new WebServiceException(AddressingMessages.FAULT_TO_CANNOT_PARSE(), e);
        }
    }

    return faultTo;
}
 

import com.sun.xml.internal.ws.resources.AddressingMessages; //导入依赖的package包/类
public static WSEndpointReference getReplyTo(@NotNull MessageHeaders headers, @NotNull AddressingVersion av, @NotNull SOAPVersion sv) {
    if (av == null) {
        throw new IllegalArgumentException(AddressingMessages.NULL_ADDRESSING_VERSION());
    }

    Header h = getFirstHeader(headers, av.replyToTag, true, sv);
    WSEndpointReference replyTo;
    if (h != null) {
        try {
            replyTo = h.readAsEPR(av);
        } catch (XMLStreamException e) {
            throw new WebServiceException(AddressingMessages.REPLY_TO_CANNOT_PARSE(), e);
        }
    } else {
        replyTo = av.anonymousEpr;
    }

    return replyTo;
}
 

import com.sun.xml.internal.ws.resources.AddressingMessages; //导入依赖的package包/类
@Override
protected void validateAction(Packet packet) {
    //There may not be a WSDL operation.  There may not even be a WSDL.
    //For instance this may be a RM CreateSequence message.
    WSDLBoundOperation wbo = getWSDLBoundOperation(packet);

    if (wbo == null)    return;

    String gotA = AddressingUtils.getAction(
            packet.getMessage().getHeaders(),
            addressingVersion, soapVersion);
    if (gotA == null)
        throw new WebServiceException(AddressingMessages.VALIDATION_CLIENT_NULL_ACTION());

    String expected = helper.getOutputAction(packet);

    if (expected != null && !gotA.equals(expected))
        throw new ActionNotSupportedException(gotA);
}
 

import com.sun.xml.internal.ws.resources.AddressingMessages; //导入依赖的package包/类
/**
 * Gets the first {@link Header} of the specified name targeted at the
 * current implicit role.
 *
 * @param name name of the header
 * @param markUnderstood
 *      If this parameter is true, the returned headers will
 *      be marked as <a href="#MU">"understood"</a> when they are returned
 *      from {@link Iterator#next()}.
 * @return null if header not found
 */
private Header getFirstHeader(QName name, boolean markUnderstood, SOAPVersion sv) {
    if (sv == null) {
        throw new IllegalArgumentException(AddressingMessages.NULL_SOAP_VERSION());
    }

    Iterator<Header> iter = getHeaders(name.getNamespaceURI(), name.getLocalPart(), markUnderstood);
    while (iter.hasNext()) {
        Header h = iter.next();
        if (h.getRole(sv).equals(sv.implicitRole)) {
            return h;
        }
    }

    return null;
}
 

import com.sun.xml.internal.ws.resources.AddressingMessages; //导入依赖的package包/类
/**
 * Returns the value of WS-Addressing <code>To</code> header. The <code>version</code>
 * identifies the WS-Addressing version and the header returned is targeted at
 * the current implicit role. Caches the value for subsequent invocation.
 * Duplicate <code>To</code> headers are detected earlier.
 *
 * @param av WS-Addressing version
 * @param sv SOAP version
 * @throws IllegalArgumentException if either <code>av</code> or <code>sv</code> is null.
 * @return Value of WS-Addressing To header, anonymous URI if no header is present
 */
public String getTo(AddressingVersion av, SOAPVersion sv) {
    if (to != null) {
        return to;
    }
    if (av == null) {
        throw new IllegalArgumentException(AddressingMessages.NULL_ADDRESSING_VERSION());
    }

    Header h = getFirstHeader(av.toTag, true, sv);
    if (h != null) {
        to = h.getStringContent();
    } else {
        to = av.anonymousUri;
    }

    return to;
}
 

import com.sun.xml.internal.ws.resources.AddressingMessages; //导入依赖的package包/类
/**
 * Returns the value of WS-Addressing <code>Action</code> header. The <code>version</code>
 * identifies the WS-Addressing version and the header returned is targeted at
 * the current implicit role. Caches the value for subsequent invocation.
 * Duplicate <code>Action</code> headers are detected earlier.
 *
 * @param av WS-Addressing version
 * @param sv SOAP version
 * @throws IllegalArgumentException if either <code>av</code> or <code>sv</code> is null.
 * @return Value of WS-Addressing Action header, null if no header is present
 */
public String getAction(@NotNull AddressingVersion av, @NotNull SOAPVersion sv) {
    if (action != null) {
        return action;
    }
    if (av == null) {
        throw new IllegalArgumentException(AddressingMessages.NULL_ADDRESSING_VERSION());
    }

    Header h = getFirstHeader(av.actionTag, true, sv);
    if (h != null) {
        action = h.getStringContent();
    }

    return action;
}
 

import com.sun.xml.internal.ws.resources.AddressingMessages; //导入依赖的package包/类
/**
 * Returns the value of WS-Addressing <code>ReplyTo</code> header. The <code>version</code>
 * identifies the WS-Addressing version and the header returned is targeted at
 * the current implicit role. Caches the value for subsequent invocation.
 * Duplicate <code>ReplyTo</code> headers are detected earlier.
 *
 * @param av WS-Addressing version
 * @param sv SOAP version
 * @throws IllegalArgumentException if either <code>av</code> or <code>sv</code> is null.
 * @return Value of WS-Addressing ReplyTo header, null if no header is present
 */
public WSEndpointReference getReplyTo(@NotNull AddressingVersion av, @NotNull SOAPVersion sv) {
    if (replyTo != null) {
        return replyTo;
    }
    if (av == null) {
        throw new IllegalArgumentException(AddressingMessages.NULL_ADDRESSING_VERSION());
    }

    Header h = getFirstHeader(av.replyToTag, true, sv);
    if (h != null) {
        try {
            replyTo = h.readAsEPR(av);
        } catch (XMLStreamException e) {
            throw new WebServiceException(AddressingMessages.REPLY_TO_CANNOT_PARSE(), e);
        }
    } else {
        replyTo = av.anonymousEpr;
    }

    return replyTo;
}
 

import com.sun.xml.internal.ws.resources.AddressingMessages; //导入依赖的package包/类
/**
 * Returns the value of WS-Addressing <code>FaultTo</code> header. The <code>version</code>
 * identifies the WS-Addressing version and the header returned is targeted at
 * the current implicit role. Caches the value for subsequent invocation.
 * Duplicate <code>FaultTo</code> headers are detected earlier.
 *
 * @param av WS-Addressing version
 * @param sv SOAP version
 * @throws IllegalArgumentException if either <code>av</code> or <code>sv</code> is null.
 * @return Value of WS-Addressing FaultTo header, null if no header is present
 */
public WSEndpointReference getFaultTo(@NotNull AddressingVersion av, @NotNull SOAPVersion sv) {
    if (faultTo != null) {
        return faultTo;
    }

    if (av == null) {
        throw new IllegalArgumentException(AddressingMessages.NULL_ADDRESSING_VERSION());
    }

    Header h = getFirstHeader(av.faultToTag, true, sv);
    if (h != null) {
        try {
            faultTo = h.readAsEPR(av);
        } catch (XMLStreamException e) {
            throw new WebServiceException(AddressingMessages.FAULT_TO_CANNOT_PARSE(), e);
        }
    }

    return faultTo;
}
 

import com.sun.xml.internal.ws.resources.AddressingMessages; //导入依赖的package包/类
/**
 * Returns the value of WS-Addressing <code>MessageID</code> header. The <code>version</code>
 * identifies the WS-Addressing version and the header returned is targeted at
 * the current implicit role. Caches the value for subsequent invocation.
 * Duplicate <code>MessageID</code> headers are detected earlier.
 *
 * @param av WS-Addressing version
 * @param sv SOAP version
 * @throws WebServiceException if either <code>av</code> or <code>sv</code> is null.
 * @return Value of WS-Addressing MessageID header, null if no header is present
 */
public String getMessageID(@NotNull AddressingVersion av, @NotNull SOAPVersion sv) {
    if (messageId != null) {
        return messageId;
    }

    if (av == null) {
        throw new IllegalArgumentException(AddressingMessages.NULL_ADDRESSING_VERSION());
    }

    Header h = getFirstHeader(av.messageIDTag, true, sv);
    if (h != null) {
        messageId = h.getStringContent();
    }

    return messageId;
}
 

import com.sun.xml.internal.ws.resources.AddressingMessages; //导入依赖的package包/类
/**
 * Returns the value of WS-Addressing <code>RelatesTo</code> header. The <code>version</code>
 * identifies the WS-Addressing version and the header returned is targeted at
 * the current implicit role. Caches the value for subsequent invocation.
 * Duplicate <code>RelatesTo</code> headers are detected earlier.
 *
 * @param av WS-Addressing version
 * @param sv SOAP version
 * @throws WebServiceException if either <code>av</code> or <code>sv</code> is null.
 * @return Value of WS-Addressing RelatesTo header, null if no header is present
 */
public String getRelatesTo(@NotNull AddressingVersion av, @NotNull SOAPVersion sv) {
    if (relatesTo != null) {
        return relatesTo;
    }

    if (av == null) {
        throw new IllegalArgumentException(AddressingMessages.NULL_ADDRESSING_VERSION());
    }

    Header h = getFirstHeader(av.relatesToTag, true, sv);
    if (h != null) {
        relatesTo = h.getStringContent();
    }

    return relatesTo;
}
 

import com.sun.xml.internal.ws.resources.AddressingMessages; //导入依赖的package包/类
@Override
protected void validateAction(Packet packet) {
    //There may not be a WSDL operation.  There may not even be a WSDL.
    //For instance this may be a RM CreateSequence message.
    WSDLBoundOperation wsdlBoundOperation = getWSDLBoundOperation(packet);

    if (wsdlBoundOperation == null)
        return;

    String gotA = packet.getMessage().getHeaders().getAction(addressingVersion, soapVersion);

    if (gotA == null)
        throw new WebServiceException(AddressingMessages.VALIDATION_SERVER_NULL_ACTION());

    String expected = helper.getInputAction(packet);
    String soapAction = helper.getSOAPAction(packet);
    if (helper.isInputActionDefault(packet) && (soapAction != null && !soapAction.equals("")))
        expected = soapAction;

    if (expected != null && !gotA.equals(expected)) {
        throw new ActionNotSupportedException(gotA);
    }
}
 

import com.sun.xml.internal.ws.resources.AddressingMessages; //导入依赖的package包/类
@Override
protected void validateAction(Packet packet) {
    //There may not be a WSDL operation.  There may not even be a WSDL.
    //For instance this may be a RM CreateSequence message.
    WSDLBoundOperation wbo = getWSDLBoundOperation(packet);

    if (wbo == null)    return;

    String gotA = packet.getMessage().getHeaders().getAction(addressingVersion, soapVersion);
    if (gotA == null)
        throw new WebServiceException(AddressingMessages.VALIDATION_CLIENT_NULL_ACTION());

    String expected = helper.getOutputAction(packet);

    if (expected != null && !gotA.equals(expected))
        throw new ActionNotSupportedException(gotA);
}
 

import com.sun.xml.internal.ws.resources.AddressingMessages; //导入依赖的package包/类
public static String getAction(@NotNull MessageHeaders headers, @NotNull AddressingVersion av, @NotNull SOAPVersion sv) {
    if (av == null) {
        throw new IllegalArgumentException(AddressingMessages.NULL_ADDRESSING_VERSION());
    }

    String action = null;
    Header h = getFirstHeader(headers, av.actionTag, true, sv);
    if (h != null) {
        action = h.getStringContent();
    }

    return action;
}
 

import com.sun.xml.internal.ws.resources.AddressingMessages; //导入依赖的package包/类
public static String getMessageID(@NotNull MessageHeaders headers, @NotNull AddressingVersion av, @NotNull SOAPVersion sv) {
    if (av == null) {
        throw new IllegalArgumentException(AddressingMessages.NULL_ADDRESSING_VERSION());
    }

    Header h = getFirstHeader(headers, av.messageIDTag, true, sv);
    String messageId = null;
    if (h != null) {
        messageId = h.getStringContent();
    }

    return messageId;
}
 

import com.sun.xml.internal.ws.resources.AddressingMessages; //导入依赖的package包/类
public static String getRelatesTo(@NotNull MessageHeaders headers, @NotNull AddressingVersion av, @NotNull SOAPVersion sv) {
    if (av == null) {
        throw new IllegalArgumentException(AddressingMessages.NULL_ADDRESSING_VERSION());
    }

    Header h = getFirstHeader(headers, av.relatesToTag, true, sv);
    String relatesTo = null;
    if (h != null) {
        relatesTo = h.getStringContent();
    }

    return relatesTo;
}
 

import com.sun.xml.internal.ws.resources.AddressingMessages; //导入依赖的package包/类
public static String getTo(MessageHeaders headers, AddressingVersion av, SOAPVersion sv) {
    if (av == null) {
        throw new IllegalArgumentException(AddressingMessages.NULL_ADDRESSING_VERSION());
    }

    Header h = getFirstHeader(headers, av.toTag, true, sv);
    String to;
    if (h != null) {
        to = h.getStringContent();
    } else {
        to = av.anonymousUri;
    }

    return to;
}
 

import com.sun.xml.internal.ws.resources.AddressingMessages; //导入依赖的package包/类
public static Header getFirstHeader(MessageHeaders headers, QName name, boolean markUnderstood, SOAPVersion sv) {
    if (sv == null) {
        throw new IllegalArgumentException(AddressingMessages.NULL_SOAP_VERSION());
    }

    Iterator<Header> iter = headers.getHeaders(name.getNamespaceURI(), name.getLocalPart(), markUnderstood);
    while (iter.hasNext()) {
        Header h = iter.next();
        if (h.getRole(sv).equals(sv.implicitRole)) {
            return h;
        }
    }

    return null;
}
 

import com.sun.xml.internal.ws.resources.AddressingMessages; //导入依赖的package包/类
protected WsaTubeHelper getTubeHelper() {
    if(binding.isFeatureEnabled(AddressingFeature.class)) {
        return new WsaTubeHelperImpl(wsdlPort, null, binding);
    } else if(binding.isFeatureEnabled(MemberSubmissionAddressingFeature.class)) {
        //seiModel is null as it is not needed.
        return new com.sun.xml.internal.ws.addressing.v200408.WsaTubeHelperImpl(wsdlPort, null, binding);
    } else {
        // Addressing is not enabled, WsaTube should not be included in the pipeline
        throw new WebServiceException(AddressingMessages.ADDRESSING_NOT_ENABLED(this.getClass().getSimpleName()));
    }
}
 

import com.sun.xml.internal.ws.resources.AddressingMessages; //导入依赖的package包/类
protected void validateSOAPAction(Packet packet) {
    String gotA = AddressingUtils.getAction(
            packet.getMessage().getHeaders(),
            addressingVersion, soapVersion);
    if (gotA == null)
        throw new WebServiceException(AddressingMessages.VALIDATION_SERVER_NULL_ACTION());
    if(packet.soapAction != null && !packet.soapAction.equals("\"\"") && !packet.soapAction.equals("\""+gotA+"\"")) {
        throw new InvalidAddressingHeaderException(addressingVersion.actionTag, addressingVersion.actionMismatchTag);
    }
}
 

import com.sun.xml.internal.ws.resources.AddressingMessages; //导入依赖的package包/类
@Override
protected void validateAction(Packet packet) {
    //There may not be a WSDL operation.  There may not even be a WSDL.
    //For instance this may be a RM CreateSequence message.
    WSDLBoundOperation wsdlBoundOperation = getWSDLBoundOperation(packet);

    if (wsdlBoundOperation == null) {
        return;
    }

    String gotA = AddressingUtils.getAction(
            packet.getMessage().getHeaders(),
            addressingVersion, soapVersion);

    if (gotA == null) {
        throw new WebServiceException(AddressingMessages.VALIDATION_SERVER_NULL_ACTION());
    }

    String expected = helper.getInputAction(packet);
    String soapAction = helper.getSOAPAction(packet);
    if (helper.isInputActionDefault(packet) && (soapAction != null && !soapAction.equals(""))) {
        expected = soapAction;
    }

    if (expected != null && !gotA.equals(expected)) {
        throw new ActionNotSupportedException(gotA);
    }
}