import com.sun.xml.internal.ws.api.message.Messages; //导入依赖的package包/类
/**
 * Replace the message in the given message context with a
 * fault message. If the context already contains a fault
 * message, then return without changing it.
 *
 * <p>This method should only be called during a request,
 * because during a response an exception from a handler
 * is dispatched rather than replacing the message with
 * a fault. So this method can use the MESSAGE_OUTBOUND_PROPERTY
 * to determine whether it is being called on the client
 * or the server side. If this changes in the spec, then
 * something else will need to be passed to the method
 * to determine whether the fault code is client or server.
 */
final void insertFaultMessage(C context,
    ProtocolException exception) {
    try {
        if(!context.getPacketMessage().isFault()) {
            Message faultMessage = Messages.create(binding.getSOAPVersion(),
                    exception,determineFaultCode(binding.getSOAPVersion()));
            context.setPacketMessage(faultMessage);
        }
    } catch (Exception e) {
        // severe since this is from runtime and not handler
        logger.log(Level.SEVERE,
            "exception while creating fault message in handler chain", e);
        throw new RuntimeException(e);
    }
}
 

import com.sun.xml.internal.ws.api.message.Messages; //导入依赖的package包/类
final void insertFaultMessage(C context,
        ProtocolException exception) {
    if(exception instanceof HTTPException) {
        context.put(MessageContext.HTTP_RESPONSE_CODE,((HTTPException)exception).getStatusCode());
    }
    if (context != null) {
        // non-soap case
        context.setPacketMessage(Messages.createEmpty(binding.getSOAPVersion()));
    }
}
 

import com.sun.xml.internal.ws.api.message.Messages; //导入依赖的package包/类
public void decode(InputStream in, String contentType, Packet packet) throws IOException {
    /* Implements similar logic as the XMLMessage.create(String, InputStream).
     * But it's faster, as we know the InputStream has FastInfoset content*/
    Message message;
    in = hasSomeData(in);
    if (in != null) {
        message = Messages.createUsingPayload(new FastInfosetSource(in),
                SOAPVersion.SOAP_11);
    } else {
        message = Messages.createEmpty(SOAPVersion.SOAP_11);
    }

    packet.setMessage(message);
}
 

import com.sun.xml.internal.ws.api.message.Messages; //导入依赖的package包/类
public WSDLOperationMapping getWSDLOperationMapping(Packet request) throws DispatchException {
    MessageHeaders hl = request.getMessage().getHeaders();
    String action = AddressingUtils.getAction(hl, av, binding.getSOAPVersion());

    if (action == null)
        // Addressing is not enagaged, return null to use other ways to dispatch.
        return null;

    Message message = request.getMessage();
    QName payloadName;
    String localPart = message.getPayloadLocalPart();
    if (localPart == null) {
        payloadName = EMPTY_PAYLOAD;
    } else {
        String nsUri = message.getPayloadNamespaceURI();
        if (nsUri == null)
            nsUri = EMPTY_PAYLOAD_NSURI;
        payloadName = new QName(nsUri, localPart);
    }

    WSDLOperationMapping opMapping = uniqueOpSignatureMap.get(new ActionBasedOperationSignature(action, payloadName));
    if (opMapping != null)
        return opMapping;

    //Seems like in Wstrust STS wsdls, the payload does not match what is specified in the wsdl leading to incorrect
    //  wsdl operation resolution. Use just wsa:Action to dispatch as a last resort.
    //try just with wsa:Action
    opMapping = actionMap.get(action);
    if (opMapping != null)
        return opMapping;

    // invalid action header
    Message result = Messages.create(action, av, binding.getSOAPVersion());

    throw new DispatchException(result);

}
 

import com.sun.xml.internal.ws.api.message.Messages; //导入依赖的package包/类
public void decode(InputStream in, String contentType, Packet packet) throws IOException {
    /* Implements similar logic as the XMLMessage.create(String, InputStream).
     * But it's faster, as we know the InputStream has FastInfoset content*/
    Message message = null;
    in = hasSomeData(in);
    if (in != null) {
        message = Messages.createUsingPayload(new FastInfosetSource(in),
                SOAPVersion.SOAP_11);
    } else {
        message = Messages.createEmpty(SOAPVersion.SOAP_11);
    }

    packet.setMessage(message);
}
 

import com.sun.xml.internal.ws.api.message.Messages; //导入依赖的package包/类
/**
 *
 * @param request  Request Packet that is used to find the associated WSDLOperation
 * @return WSDL operation Qname.
 *         return null if WS-Addressing is not engaged.
 * @throws DispatchException with WSA defined fault message when it cannot find an associated WSDL operation.
 *
 */
@Override
public QName getWSDLOperationQName(Packet request) throws DispatchException {
    HeaderList hl = request.getMessage().getHeaders();
    String action = hl.getAction(av, binding.getSOAPVersion());

    if (action == null)
        // Addressing is not enagaged, return null to use other ways to dispatch.
        return null;

    Message message = request.getMessage();
    QName payloadName;
    String localPart = message.getPayloadLocalPart();
    if (localPart == null) {
        payloadName = EMPTY_PAYLOAD;
    } else {
        String nsUri = message.getPayloadNamespaceURI();
        if (nsUri == null)
            nsUri = EMPTY_PAYLOAD_NSURI;
        payloadName = new QName(nsUri, localPart);
    }

    QName opName = uniqueOpSignatureMap.get(new ActionBasedOperationSignature(action, payloadName));
    if (opName != null)
        return opName;

    //Seems like in Wstrust STS wsdls, the payload does not match what is specified in the wsdl leading to incorrect
    //  wsdl operation resolution. Use just wsa:Action to dispatch as a last resort.
    //try just with wsa:Action
    opName = actionMap.get(action);
    if (opName != null)
        return opName;

    // invalid action header
    Message result = Messages.create(action, av, binding.getSOAPVersion());

    throw new DispatchException(result);

}
 

import com.sun.xml.internal.ws.api.message.Messages; //导入依赖的package包/类
Message createMessage(Object[] methodArgs) {
    return Messages.createEmpty(soapVersion);
}
 

import com.sun.xml.internal.ws.api.message.Messages; //导入依赖的package包/类
public Message createMessage(Object[] methodArgs, Object returnValue) {
    return Messages.createEmpty(soapVersion);
}
 

import com.sun.xml.internal.ws.api.message.Messages; //导入依赖的package包/类
public Message getResponseMessage(Source source) {
    return Messages.createUsingPayload(source, SOAPVersion.SOAP_11);
}
 

import com.sun.xml.internal.ws.api.message.Messages; //导入依赖的package包/类
protected Message getResponseMessage(Source source) {
    return Messages.createUsingPayload(source, soapVersion);
}