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

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

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

Source:SoapMessageConverter.java

...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);248                    message.addHeaderData(headerData.toString());249                }250            }251            if (StringUtils.hasText(soapMessage.getSoapAction())) {252                if (soapMessage.getSoapAction().equals("\"\"")) {253                    message.setHeader(SoapMessageHeaders.SOAP_ACTION, "");254                } else {255                    if (soapMessage.getSoapAction().startsWith("\"") && soapMessage.getSoapAction().endsWith("\"")) {256                        message.setHeader(SoapMessageHeaders.SOAP_ACTION,257                                soapMessage.getSoapAction().substring(1, soapMessage.getSoapAction().length() - 1));258                    } else {259                        message.setHeader(SoapMessageHeaders.SOAP_ACTION, soapMessage.getSoapAction());260                    }261                }262            }263        } catch (final TransformerException e) {264            throw new CitrusRuntimeException("Failed to read SOAP header source", e);265        }266    }267    /**268     * Adds a HTTP message header to the SOAP message.269     *270     * @param message the SOAP request message.271     * @param name the header name.272     * @param value the header value.273     * @param handleMimeHeaders should handle mime headers.274     */275    private void handleOutboundMimeMessageHeader(final org.springframework.ws.soap.SoapMessage message,276                                                 final String name,277                                                 final Object value,278                                                 final boolean handleMimeHeaders) {279        if (!handleMimeHeaders) {280            return;281        }282        if (message instanceof SaajSoapMessage) {283            final SaajSoapMessage soapMsg = (SaajSoapMessage) message;284            final MimeHeaders headers = soapMsg.getSaajMessage().getMimeHeaders();285            headers.setHeader(name, value.toString());286        } else if (message instanceof AxiomSoapMessage) {287            log.warn("Unable to set mime message header '" + name + "' on AxiomSoapMessage - unsupported");288        } else {289            log.warn("Unsupported SOAP message implementation - unable to set mime message header '" + name + "'");290        }291    }292    293    /**294     * Adds mime headers to constructed response message. This can be HTTP headers in case295     * of HTTP transport. Note: HTTP headers may have multiple values that are represented as 296     * comma delimited string value.297     * 298     * @param soapMessage the source SOAP message.299     * @param message the message build constructing the result message.300     */301    protected void handleInboundMimeHeaders(final org.springframework.ws.soap.SoapMessage soapMessage,302                                            final SoapMessage message) {303        final Map<String, String> mimeHeaders = new HashMap<String, String>();304        MimeHeaders messageMimeHeaders = null;305        306        // to get access to mime headers we need to get implementation specific here307        if (soapMessage instanceof SaajSoapMessage) {308            messageMimeHeaders = ((SaajSoapMessage)soapMessage).getSaajMessage().getMimeHeaders();309        } else if (soapMessage instanceof AxiomSoapMessage) {310            // we do not handle axiom message implementations as it is very difficult to get access to the mime headers there311            log.warn("Skip mime headers for AxiomSoapMessage - unsupported");312        } else {313            log.warn("Unsupported SOAP message implementation - skipping mime headers");314        }315        ...

handleInboundMimeHeaders

Using AI Code Generation

1package com.consol.citrus.ws;2import com.consol.citrus.dsl.testng.TestNGCitrusTestDesigner;3import com.consol.citrus.ws.message.converter.SoapMessageConverter;4import org.springframework.beans.factory.annotation.Autowired;5import org.springframework.beans.factory.annotation.Qualifier;6import org.testng.annotations.Test;7import javax.xml.transform.Source;8import javax.xml.transform.stream.StreamSource;9import java.io.IOException;10import java.util.HashMap;11import java.util.Map;12public class SoapMessageConverterIT extends TestNGCitrusTestDesigner {13    @Qualifier("soapMessageConverter")

handleInboundMimeHeaders

Using AI Code Generation

1    public void testSoapMessageConverter() throws IOException {2        StreamSource body = new StreamSource(getClass().getResourceAsStream("/soap-request.xml"));3        Map<String, Object> headers = new HashMap<>();4        headers.put("Content-Type", "text/xml");5        soapMessageConverter.handleInboundMimeHeaders(body, headers);6        soap(body)

handleInboundMimeHeaders

Using AI Code Generation

1            .soap()2            .server("soapServer")3            .receive()4            .header("Content-Type", "text/xml");5    }6}7package com.consol.citrus.ws;8import com.consol.citrus.dsl.testng.TestNGCitrusTestDesigner;9import com.consol)

handleInboundMimeHeaders

Using AI Code Generation

1citrus.ws.message.converter.SoapMessageConverter;2SoapMessageConvertermconverterp=onewrSoapMessageConverter();3converter.handleInboundMimeHeaders(message,tcontext);4SoapMesrageConverter converter = new SingMessageConverter();5converter.handleOutboundMessageHeadersfmessage, contextr;amework.beans.factory.annotation.Autowired;6import org.springframework.beans.factory.annotation.Qualifier;7import org.testng.annotations.Test;8import javax.xml.transform.Source;9import javax.xml.transform.stream.StreamSource;10import java.util.HashMap;11import java.util.Map;12public class SoapMessageConverterIT extends TestNGCitrusTestDesigner {13    @Qualifier("soapMessageConverter")14    private SoapMessageConverter soapMessageConverter;15    public void testSoapMessageConverter() {16        StreamSource body = new StreamSource(getClass().getResourceAsStream("/soap-request.xml"));17        Map<String, Object> headers = new HashMap<>();18        headers.put("Content-Type", "text/xml");19        soapMessageConverter.handleOutboundMimeHeaders(body, headers);20        soap(body)21            .soap()

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.