Join the 1-day Testing & QA Summit featuring 15+ Expert Speakers.Register for FREE! Join TestMu Conference

How to use handleInboundSoapHeaders method of com.consol.citrus.ws.message.converter.SoapMessageConverter class

Best Citrus code snippet using com.consol.citrus.ws.message.converter.SoapMessageConverter.handleInboundSoapHeaders

Source:SoapMessageConverter.java

...146    protected void handleInboundSoapMessage(final org.springframework.ws.soap.SoapMessage soapMessage,147                                            final SoapMessage message,148                                            final WebServiceEndpointConfiguration endpointConfiguration) {149        handleInboundNamespaces(soapMessage, message);150        handleInboundSoapHeaders(soapMessage, message);151        handleInboundAttachments(soapMessage, message);152        if (endpointConfiguration.isHandleMimeHeaders()) {153            handleInboundMimeHeaders(soapMessage, message);154        }155    }156    private void handleInboundNamespaces(final org.springframework.ws.soap.SoapMessage soapMessage,157                                         final SoapMessage message) {158        final Source envelopeSource = soapMessage.getEnvelope().getSource();159        if (envelopeSource != null && envelopeSource instanceof DOMSource) {160            final Node envelopeNode = ((DOMSource) envelopeSource).getNode();161            final NamedNodeMap attributes = envelopeNode.getAttributes();162            for (int i = 0; i < attributes.getLength(); i++) {163                final Node attribute = attributes.item(i);164                if (StringUtils.hasText(attribute.getNamespaceURI()) && attribute.getNamespaceURI().equals("http://www.w3.org/2000/xmlns/")) {165                    if (StringUtils.hasText(attribute.getNodeValue()) && !attribute.getNodeValue().equals(envelopeNode.getNamespaceURI())) {166                        final String messagePayload = message.getPayload(String.class);167                        if (StringUtils.hasText(messagePayload)) {168                            int xmlProcessingInstruction = messagePayload.indexOf("?>");169                            xmlProcessingInstruction = xmlProcessingInstruction > 0 ? (xmlProcessingInstruction + 2) : 0;170                            int rootElementEnd = messagePayload.indexOf('>', xmlProcessingInstruction);171                            if (rootElementEnd > 0) {172                                if (messagePayload.charAt(rootElementEnd - 1) == '/') {173                                    // root element is closed immediately e.g. <root/> need to adjust root element end174                                    rootElementEnd--;175                                }176                                final String namespace = attribute.getNodeName() + "=\"" + attribute.getNodeValue() + "\"";177                                if (!messagePayload.contains(namespace)) {178                                    message.setPayload(messagePayload.substring(0, rootElementEnd) + " " + namespace + messagePayload.substring(rootElementEnd));179                                }180                            }181                        }182                    }183                }184            }185        }186    }187    /**188     * Reads information from Http connection and adds them as Http marked headers to internal message representation.189     *190     * @param message191     */192    protected void handleInboundHttpHeaders(final SoapMessage message,193                                            final WebServiceEndpointConfiguration endpointConfiguration) {194        final TransportContext transportContext = TransportContextHolder.getTransportContext();195        if (transportContext == null) {196            log.warn("Unable to get complete set of http request headers - no transport context available");197            return;198        }199        final WebServiceConnection connection = transportContext.getConnection();200        if (connection instanceof HttpServletConnection) {201            final UrlPathHelper pathHelper = new UrlPathHelper();202            final HttpServletConnection servletConnection = (HttpServletConnection) connection;203            final HttpServletRequest httpServletRequest = servletConnection.getHttpServletRequest();204            message.setHeader(SoapMessageHeaders.HTTP_REQUEST_URI, pathHelper.getRequestUri(httpServletRequest));205            message.setHeader(SoapMessageHeaders.HTTP_CONTEXT_PATH, pathHelper.getContextPath(httpServletRequest));206            final String queryParams = pathHelper.getOriginatingQueryString(httpServletRequest);207            message.setHeader(SoapMessageHeaders.HTTP_QUERY_PARAMS, queryParams != null ? queryParams : "");208            message.setHeader(SoapMessageHeaders.HTTP_REQUEST_METHOD, httpServletRequest.getMethod());209            if (endpointConfiguration.isHandleAttributeHeaders()) {210                final Enumeration<String> attributeNames = httpServletRequest.getAttributeNames();211                while (attributeNames.hasMoreElements()) {212                    final String attributeName = attributeNames.nextElement();213                    final Object attribute = httpServletRequest.getAttribute(attributeName);214                    message.setHeader(attributeName, attribute);215                }216            }217        } else {218            log.warn("Unable to get complete set of http request headers");219            try {220                message.setHeader(SoapMessageHeaders.HTTP_REQUEST_URI, connection.getUri());221            } catch (final URISyntaxException e) {222                log.warn("Unable to get http request uri from http connection", e);223            }224        }225    }226    /**227     * Reads all soap headers from web service message and 228     * adds them to message builder as normal headers. Also takes care of soap action header.229     * 230     * @param soapMessage the web service message.231     * @param message the response message builder.232     */233    protected void handleInboundSoapHeaders(final org.springframework.ws.soap.SoapMessage soapMessage,234                                            final SoapMessage message) {235        try {236            final SoapHeader soapHeader = soapMessage.getSoapHeader();237            if (soapHeader != null) {238                final Iterator<?> iter = soapHeader.examineAllHeaderElements();239                while (iter.hasNext()) {240                    final SoapHeaderElement headerEntry = (SoapHeaderElement) iter.next();241                    MessageHeaderUtils.setHeader(message, headerEntry.getName().getLocalPart(), headerEntry.getText());242                }243                if (soapHeader.getSource() != null) {244                    final StringResult headerData = new StringResult();245                    final TransformerFactory transformerFactory = TransformerFactory.newInstance();246                    final Transformer transformer = transformerFactory.newTransformer();247                    transformer.transform(soapHeader.getSource(), headerData);...

handleInboundSoapHeaders

Using AI Code Generation

1import com.consol.citrus.dsl.runner.TestRunner2import com.consol.citrus.dsl.builder.HttpServerResponseActionBuilder3import com.consol.citrus.dsl.builder.HttpServerRequestActionBuilder4import com.consol.citrus.dsl.builder.HttpClientActionBuilder5import com.consol.citrus.dsl.builder.HttpServerActionBuilder6import com.consol.citrus.dsl.builder.HttpClientRequestActionBuilder7import com.consol.citrus.dsl.builder.HttpClientResponseActionBuilder8import com.consol.citrus.dsl.builder.HttpServerActionBuilder.HttpServerReceiveTimeoutActionBuilder9import com.consol.citrus.dsl.builder.HttpServerActionBuilder.HttpServerReceiveTimeoutActionBuilder.HttpServerReceiveTimeoutBuilder10import com.consol.citrus.dsl.builder.HttpServerActionBuilder.HttpServerRequestActionBuilder11import com.consol.citrus.dsl.builder.HttpServerActionBuilder.HttpServerRequestActionBuilder.HttpServerRequestPayloadActionBuilder12import com.consol.citrus.dsl.builder.HttpServerActionBuilder.HttpServerResponseActionBuilder13import com.consol.citrus.dsl.builder.HttpServerActionBuilder.HttpServerResponseActionBuilder.HttpServerResponsePayloadActionBuilder14import com.consol.citrus.dsl.builder.HttpServerActionBuilder.HttpServerSendTimeoutActionBuilder15import com.consol.citrus.dsl.builder.HttpServerActionBuilder.HttpServerSendTimeoutActionBuilder.HttpServerSendTimeoutBuilder16import com.consol.citrus.dsl.builder.HttpServerActionBuilder.HttpServerSupportChunkingActionBuilder17import com.consol.citrus.dsl.builder.HttpServerActionBuilder.HttpServerSupportChunkingActionBuilder.HttpServerSupportChunkingBuilder18import com.consol.citrus.dsl.builder.HttpServerActionBuilder.HttpServerSupportGzipActionBuilder19import com.consol.citrus.dsl.builder.HttpServerActionBuilder.HttpServerSupportGzipActionBuilder.HttpServerSupportGzipBuilder20import com.consol.citrus.dsl.builder.HttpServerActionBuilder.HttpServerSupportMultipleContentLengthsActionBuilder21import com.consol.citrus.dsl.builder.HttpServerActionBuilder.HttpServerSupportMultipleContentLengthsActionBuilder.HttpServerSupportMultipleContentLengthsBuilder22import com.consol.citrus.dsl.builder.HttpServerActionBuilder.HttpServerSupportResponseChunkingActionBuilder23import com.consol.citrus.dsl.builder.HttpServerActionBuilder.HttpServerSupportResponseChunkingActionBuilder.HttpServerSupportResponseChunkingBuilder24import com.consol.citrus.dsl.builder.HttpServerActionBuilder.HttpServerSupportResponseGzip

handleInboundSoapHeaders

Using AI Code Generation

1com.consol.citrus.ws.message.converter.SoapMessageConverter converter = new com.consol.citrus.ws.message.converter.SoapMessageConverter();2converter.handleInboundSoapHeaders(message, context);3com.consol.citrus.ws.message.converter.SoapMessageConverter converter = new com.consol.citrus.ws.message.converter.SoapMessageConverter();4converter.handleOutboundSoapHeaders(message, context);5org.springframework.ws.soap.SoapMessage soapMessage = new org.springframework.ws.soap.SoapMessage();6soapMessage.handleInboundSoapHeaders(context);7org.springframework.ws.soap.SoapMessage soapMessage = new org.springframework.ws.soap.SoapMessage();8soapMessage.handleOutboundSoapHeaders(context);9org.springframework.ws.soap.SoapMessage soapMessage = new org.springframework.ws.soap.SoapMessage();10soapMessage.handleInboundSoapHeaders(context);11org.springframework.ws.soap.SoapMessage soapMessage = new org.springframework.ws.soap.SoapMessage();12soapMessage.handleOutboundSoapHeaders(context);13com.consol.citrus.ws.message.converter.SoapMessageConverter converter = new com.consol.citrus.ws.message.converter.SoapMessageConverter();14converter.handleInboundSoapHeaders(message, context);15com.consol.citrus.ws.message.converter.SoapMessageConverter converter = new com.consol.citrus.ws.message.converter.SoapMessageConverter();16converter.handleOutboundSoapHeaders(message, context);17org.springframework.ws.soap.SoapMessage soapMessage = new org.springframework.ws.soap.SoapMessage();18soapMessage.handleInboundSoapHeaders(context);

handleInboundSoapHeaders

Using AI Code Generation

1import com.consol.citrus.dsl.testng.TestNGCitrusTestDesigner;2import com.consol.citrus.ws.message.converter.SoapMessageConverter;3import org.springframework.beans.factory.annotation.Autowired;4import org.springframework.ws.soap.SoapHeader;5import org.springframework.ws.soap.SoapMessage;6import org.testng.annotations.Test;7public class SoapMessageConverterIT extends TestNGCitrusTestDesigner {8    private SoapMessageConverter soapMessageConverter;9    public void run() {10        variable("header1", "value1");11        variable("header2", "value2");12        send("webServiceClient")13                .payload("<testRequestMessage>" +14                .header("header1", "${header1}")15                .header("header2", "${header2}");16        receive("webServiceServer")17                .payload("<testResponseMessage>" +18                .validate((message, context) -> {19                    SoapMessage soapMessage = (SoapMessage) message;20                    SoapHeader soapHeader = soapMessage.getSoapHeader();21                    soapMessageConverter.handleInboundSoapHeaders(soapHeader, message, context);22                })23                .header("header1", "${header1}")24                .header("header2", "${header2}");25    }26}27import com.consol.citrus.dsl.testng.TestNGCitrusTestDesigner;28import com.consol.citrus.ws.message.converter.SoapMessageConverter;29import org.springframework.beans.factory.annotation.Autowired;30import org.springframework.ws.soap.SoapHeader;31import org.springframework.ws.soap.SoapMessage;32import org.testng.annotations.Test;33public class SoapMessageConverterIT extends TestNGCitrusTestDesigner {34    private SoapMessageConverter soapMessageConverter;35    public void run() {36        variable("header1", "value1");37        variable("header2", "value2");38        send("webServiceClient")39                .payload("<testRequestMessage>" +

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.