Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use addMimeHeaders method of com.consol.citrus.ws.server.WebServiceEndpoint class

Best Citrus code snippet using com.consol.citrus.ws.server.WebServiceEndpoint.addMimeHeaders

Source:WebServiceEndpoint.java

...103                addSoapBody(response, replyMessage);104            }105            addSoapAttachments(response, replyMessage);106            addSoapHeaders(response, replyMessage);107            addMimeHeaders(response, replyMessage);108        } else {109            if (log.isDebugEnabled()) {110                log.debug("No reply message from endpoint adapter '" + endpointAdapter + "'");111            }112            log.warn("No SOAP response for calling client");113        }114    }115    private void addSoapAttachments(MimeMessage response, Message replyMessage) {116        if (replyMessage instanceof com.consol.citrus.ws.message.SoapMessage) {117            List<SoapAttachment> soapAttachments = ((com.consol.citrus.ws.message.SoapMessage) replyMessage).getAttachments();118            soapAttachments.stream()119                    .filter(soapAttachment -> !soapAttachment.isMtomInline())120                    .forEach(soapAttachment -> {121                        String contentId = soapAttachment.getContentId();122                        if (!contentId.startsWith("<")) {123                            contentId = "<" + contentId + ">";124                        }125                        response.addAttachment(contentId, soapAttachment.getDataHandler());126                    });127        }128    }129    /**130     * If Http status code is set on reply message headers simulate Http error with status code.131     * No SOAP response is sent back in this case.132     * @param replyMessage133     * @return134     * @throws IOException 135     */136    private boolean simulateHttpStatusCode(Message replyMessage) throws IOException {137        if (replyMessage == null || CollectionUtils.isEmpty(replyMessage.getHeaders())) {138            return false;139        }140        141        for (Entry<String, Object> headerEntry : replyMessage.getHeaders().entrySet()) {142            if (headerEntry.getKey().equalsIgnoreCase(SoapMessageHeaders.HTTP_STATUS_CODE)) {143                WebServiceConnection connection = TransportContextHolder.getTransportContext().getConnection();144                145                int statusCode = Integer.valueOf(headerEntry.getValue().toString());146                if (connection instanceof HttpServletConnection) {147                    ((HttpServletConnection)connection).setFault(false);148                    ((HttpServletConnection)connection).getHttpServletResponse().setStatus(statusCode);149                    return true;150                } else {151                    log.warn("Unable to set custom Http status code on connection other than HttpServletConnection (" + connection.getClass().getName() + ")");152                }153            }154        }155        156        return false;157    }158    /**159     * Adds mime headers outside of SOAP envelope. Header entries that go to this header section 160     * must have internal http header prefix defined in {@link com.consol.citrus.ws.message.SoapMessageHeaders}.161     * @param response the soap response message.162     * @param replyMessage the internal reply message.163     */164    private void addMimeHeaders(SoapMessage response, Message replyMessage) {165        for (Entry<String, Object> headerEntry : replyMessage.getHeaders().entrySet()) {166            if (headerEntry.getKey().toLowerCase().startsWith(SoapMessageHeaders.HTTP_PREFIX)) {167                String headerName = headerEntry.getKey().substring(SoapMessageHeaders.HTTP_PREFIX.length());168                169                if (response instanceof SaajSoapMessage) {170                    SaajSoapMessage saajSoapMessage = (SaajSoapMessage) response;171                    MimeHeaders headers = saajSoapMessage.getSaajMessage().getMimeHeaders();172                    headers.setHeader(headerName, headerEntry.getValue().toString());173                } else if (response instanceof AxiomSoapMessage) {174                    log.warn("Unable to set mime message header '" + headerName + "' on AxiomSoapMessage - unsupported");175                } else {176                    log.warn("Unsupported SOAP message implementation - unable to set mime message header '" + headerName + "'");177                }178            }...

addMimeHeaders

Using AI Code Generation

1import com.consol.citrus.annotations.CitrusTest2import com.consol.citrus.dsl.junit.JUnit4CitrusTestDesigner3import com.consol.citrus.message.MessageType4import com.consol.citrus.ws.message.SoapMessage5import org.junit.Test6import org.springframework.http.HttpStatus7class SoapTest extends JUnit4CitrusTestDesigner {8    void test() {9        variable("responseCode", "200")10        variable("responseText", "OK")11        soap().server("soapServer")12                .receive()13                .soapAction("echo")14                .header("Content-Type", "text/xml")15                .header("Accept", "text/xml")16                .header("Accept-Encoding", "gzip,deflate")17                .header("SOAPAction", "echo")18                .header("User-Agent", "Apache-CXF/3.1.14")19                .header("Host", "localhost:8080")20                .header("Connection", "Keep-Alive")21                .header("Content-Length", "130")22                .extractFromHeader("citrus_jms_messageId", "messageId")23        soap().server("soapServer")24                .send()25                .header("Content-Type", "text/xml")26                .header("Accept", "text/xml")27                .header("Accept-Encoding", "gzip,deflate")28                .header("SOAPAction", "echo")29                .header("User-Agent", "Apache-CXF/3.1.14")30                .header("Host", "localhost:8080")31                .header("Connection", "Keep-Alive")32                .header("Content-Length", "130")33                .header("citrus_jms_messageId", "${messageId}")34                .header("citrus_jms_correlationId", "${messageId}")35    }36}

addMimeHeaders

Using AI Code Generation

1import com.consol.citrus.dsl.runner.TestRunner2import com.consol.citrus.dsl.runner.TestRunnerSupport3import com.consol.citrus.dsl.testng.TestNGCitrusTestRunner4import com.consol.citrus.message.MessageType5import com.consol.citrus.ws.message.SoapMessage6import com.consol.citrus.ws.server.WebServiceEndpoint7import org.springframework.beans.factory.annotation.Autowired8import org.springframework.http.HttpMethod9import org.springframework.http.HttpStatus10import org.springframework.http.MediaType11import org.springframework.http.client.ClientHttpResponse12import org.springframework.web.client.DefaultResponseErrorHandler13import org.springframework.web.client.RestTemplate14import org.testng.annotations.Test15import javax.xml.transform.stream.StreamSource16import java.io.ByteArrayInputStream17class WebServiceEndpointTest extends TestNGCitrusTestRunner {18    void testWebServiceEndpoint() {19                .name('WebServiceEndpoint')20                .autoStart(true)21                .port(8080)22                .contextPath('citrus-ws')23                .addMimeHeaders('Content-Type', 'application/xml')24        send(http()25                .client('httpClient')26                .send()27                .post()28                .fork(true)29                .contentType('text/plain')30                .payload('Hello World!')31                .header('X-Test-Header', 'Test')32                .header('Content-Type', 'text/plain')33                .header('Accept', 'application/xml')34                .header('Accept-Encoding', 'gzip,deflate')35                .header('Connection', 'Keep-Alive')36                .header('User-Agent', 'Apache-HttpClient/4.5.3 (Java/1.8.0_181)')37                .header('Host', 'localhost:8080')38                .header('Content-Length', '12')39                .header('Expect', '100-continue')40                .header('Cookie', 'JSESSIONID=7B0B1D5C9A9F2D8A0B9AEEA9C7F8C0A8')41                .header('Accept-Charset', 'UTF-8')42                .header('X-

addMimeHeaders

Using AI Code Generation

1import com.consol.citrus.annotations.CitrusTest;2import com.consol.citrus.dsl.junit.JUnit4CitrusTestDesigner;3import com.consol.citrus.dsl.testng.TestNGCitrusTestDesigner;4import com.consol.citrus.testng.CitrusParameters;5import org.testng.annotations.DataProvider;6import org.testng.annotations.Test;7public class CitrusTest extends JUnit4CitrusTestDesigner {

addMimeHeaders

Using AI Code Generation

1package com.consol.citrus.examples;2import com.consol.citrus.annotations.CitrusTest;3import com.consol.citrus.dsl.junit.JUnit4CitrusTestRunner;4import com.consol.citrus.dsl.testng.TestNGCitrusTestRunner;5import com.consol.citrus.message.MessageType;6import com.consol.citrus.ws.message.SoapAttachment;7import com.consol.citrus.ws.message.SoapMessageHeaders;8import org.springframework.core.io.ClassPathResource;9import org.testng.annotations.Test;10import java.io.IOException;11import java.util.HashMap;12import java.util.Map;13import static com.consol.citrus.actions.CreateVariablesAction.Builder.createVariable;14import static com.consol.citrus.actions.EchoAction.Builder.echo;15import static com.consol.citrus.actions.SendMessageAction.Builder.send;16import static com.consol.citrus.actions.ReceiveMessageAction.Builder.receive;17import static com.consol.citrus.container.Assert.Builder.assertException;18import static com.consol.citrus.container.Sequence.Builder.sequential;19import static com.consol.citrus.container.Parallel.Builder.parallel;20import static com.consol.citrus.container.FinallySequence.Builder.finallySequence;21import static com.consol.citrus.container.Wait.Builder.wait;22import static com.consol.citrus.dsl.builder.Builder.Builder;23import static com.consol.citrus.dsl.builder.Builder.applyBehavior;24import static com.consol.citrus.dsl.builder.Builder.applyBehaviorOnException;25import static com.consol.citrus.dsl.builder.Builder.applyBehaviorOnExceptionFor;26import static com.consol.citrus.dsl.builder.Builder.applyBehaviorOnExceptionForBuilder;27import static com.consol.citrus.dsl.builder.Builder.applyBehaviorOnExceptionForBuilderFor;28import static com.consol.citrus.dsl.builder.Builder.applyBehaviorOnExceptionForBuilderForBuilder;29import static com.consol.citrus.dsl.builder.Builder.applyBehaviorOnExceptionForBuilderForBuilderFor;30import static com.consol.citrus.dsl.builder.Builder.applyBehaviorOnExceptionForBuilderForBuilderForBuilder;31import static com.consol.citrus.dsl.builder.Builder.applyBehaviorOnExceptionForBuilderForBuilderForBuilderFor;32import static com.consol.citrus.dsl.builder.Builder.applyBehaviorOnExceptionForBuilderForBuilderForBuilderForBuilder;33import static com.consol.citrus.dsl.builder.Builder.applyBehaviorOnExceptionForBuilderForBuilderForBuilderForBuilderFor;34import static com.con

addMimeHeaders

Using AI Code Generation

1import com.consol.citrus.dsl.endpoint.CitrusEndpoints;2import com.consol.citrus.dsl.endpoint.CitrusEndpoints.http;3import com.consol.citrus.dsl.endpoint.CitrusEndpoints.httpServer;4import com.consol.citrus.dsl.endpoint.CitrusEndpoints.soap;5import com.consol.citrus.dsl.endpoint.CitrusEndpoints.soapServer;6import com.consol.citrus.dsl.endpoint.CitrusEndpoints.ws;7import com.consol.citrus.dsl.endpoint.CitrusEndpoints.wsServer;8import com.consol.citrus.dsl.runner.TestRunner;9import com.consol.citrus.message.MessageType;10import com.consol.citrus.ws.message.SoapAttachment;11import com.consol.citrus.ws.message.SoapAttachmentBuilder;12import java.util.ArrayList;13import java.util.HashMap;14import java.util.List;15import java.util.Map;16import com.consol.citrus.dsl.testng.TestNGCitrusTestDesigner;17import org.springframework.core.io.ClassPathResource;18import org.springframework.http.HttpStatus;19import org.springframework.http.MediaType;20import org.testng.annotations.Test;21public class WebServiceServerJavaIT extends TestNGCitrusTestDesigner {22    public void testWebServiceServer() {23        soapServer()24            .autoStart(true)25            .port(8080)26            .interceptor("logging-soap-interceptor")27            .interceptor("xop-soap-interceptor")28            .interceptor("security-soap-interceptor")29            .interceptor("soap-validation-interceptor")30            .interceptor("soap-header-interceptor")31            .interceptor("soap-fault-interceptor")32            .interceptor("soap-attachment-interceptor")33            .interceptor("soap-envelope-interceptor")34            .interceptor("soap-must-understand-interceptor")35            .interceptor("soap-actor-interceptor")36            .interceptor("soap-namespace-interceptor")37            .interceptor("soap-action-interceptor")38            .interceptor("soap-header-validation-interceptor")39            .interceptor("soap-exception-interceptor")40            .interceptor("soap-attachment-validation-interceptor")41            .interceptor("soap-attachment-removal-interceptor")42            .interceptor("soap-attachment-extraction-interceptor")43            .interceptor("soap-attachment-removal-interceptor")44            .interceptor("soap-attachment-ex

addMimeHeaders

Using AI Code Generation

1public class WebServiceServerTest extends TestNGCitrusTestRunner {2    public void webServiceServerTest() {3        variable("operationName", "getCityForecastByZIP");4        variable("zipCode", "10001");5        variable("city", "New York");6        echo("Sending SOAP request message");7        send(webServiceServer("webServiceServer")8                .soap()9                .messageType("text/xml")10                        "         <weat:ZIP>${zipCode}</weat:ZIP>\n" +11                        "</soapenv:Envelope>"));12        echo("Receiving SOAP response message");13        receive(webServiceClient("webServiceClient")14                .soap()15                .messageType("text/xml")16                        "            <weat:City>${city}</weat:City>\n" +

addMimeHeaders

Using AI Code Generation

1import com.consol.citrus.dsl.design.TestDesigner2import com.consol.citrus.dsl.design.TestDesignerRunner3import com.consol.citrus.dsl.design.TestRunner4import com.consol.citrus.ws.client.WebServiceClient5import com.consol.citrus.ws.server.WebServiceEndpoint6import org.springframework.beans.factory.annotation.Autowired7import org.springframework.core.io.ClassPathResource8import org.springframework.http.HttpStatus9import org.springframework.http.MediaType10import org.springframework.test.context.ContextConfiguration11import org.springframework.test.context.TestPropertySource12import org.springframework.test.context.testng.AbstractTestNGSpringContextTests13import org.testng.annotations.Test14import static com.consol.citrus.actions.SendMessageAction.Builder.send15import static com.consol.citrus.actions.EchoAction.Builder.echo16import static com.consol.citrus.actions.CreateVariablesAction.Builder.createVariable17import static com.consol.citrus.actions.PurgeEndpointAction.Builder.purgeEndpoint18import static com.consol.citrus.container.Parallel.Builder.parallel19import static com.consol.citrus.container.Sequence.Builder.sequential20import static com.consol.citrus.dsl.builder.BuilderSupport.variable21import static com.consol.citrus.dsl.builder.BuilderSupport.value22import static com.consol.citrus.dsl.builder.BuilderSupport.xpath23import static com.consol.citrus.dsl.builder.BuilderSupport.xpathBuilder24import static com.consol.citrus.ws.actions.ReceiveSoapMessageAction.Builder.receive25import static com.consol.citrus.ws.actions.SendSoapMessageAction.Builder.soap26import static com.consol.citrus.ws.actions.SoapActionBuilder.soap27import static com.consol.citrus.ws.actions.SoapActionBuilder.soap28@ContextConfiguration(classes = [CitrusConfig::class])29@TestPropertySource(properties = ["citrus.ws.server.port=8080"])30class WebServiceEndpointAddMimeHeadersTest : AbstractTestNGSpringContextTests() {

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.