How to use interceptor method of com.consol.citrus.ws.client.WebServiceClientBuilder class

Best Citrus code snippet using com.consol.citrus.ws.client.WebServiceClientBuilder.interceptor

Source:WebServiceClientBuilder.java

...20import com.consol.citrus.message.MessageCorrelator;21import com.consol.citrus.ws.message.converter.WebServiceMessageConverter;22import org.springframework.ws.WebServiceMessageFactory;23import org.springframework.ws.client.core.WebServiceTemplate;24import org.springframework.ws.client.support.interceptor.ClientInterceptor;25import org.springframework.ws.transport.WebServiceMessageSender;26import java.util.List;27/**28 * @author Christoph Deppisch29 * @since 2.530 */31public class WebServiceClientBuilder extends AbstractEndpointBuilder<WebServiceClient> {32    /** Endpoint target */33    private WebServiceClient endpoint = new WebServiceClient();34    @Override35    protected WebServiceClient getEndpoint() {36        return endpoint;37    }38    /**39     * Sets the defaultUri property.40     * @param uri41     * @return42     */43    public WebServiceClientBuilder defaultUri(String uri) {44        endpoint.getEndpointConfiguration().setDefaultUri(uri);45        return this;46    }47    /**48     * Sets the messageFactory property.49     * @param messageFactory50     * @return51     */52    public WebServiceClientBuilder messageFactory(WebServiceMessageFactory messageFactory) {53        endpoint.getEndpointConfiguration().setMessageFactory(messageFactory);54        return this;55    }56    /**57     * Sets the keepSoapEnvelope property.58     * @param flag59     * @return60     */61    public WebServiceClientBuilder keepSoapEnvelope(boolean flag) {62        endpoint.getEndpointConfiguration().setKeepSoapEnvelope(flag);63        return this;64    }65    /**66     * Sets the web service template.67     * @param webServiceTemplate68     * @return69     */70    public WebServiceClientBuilder webServiceTemplate(WebServiceTemplate webServiceTemplate) {71        endpoint.getEndpointConfiguration().setWebServiceTemplate(webServiceTemplate);72        return this;73    }74    /**75     * Sets the message sender.76     * @param messageSender77     * @return78     */79    public WebServiceClientBuilder messageSender(WebServiceMessageSender messageSender) {80        endpoint.getEndpointConfiguration().setMessageSender(messageSender);81        return this;82    }83    /**84     * Sets the message converter.85     * @param messageConverter86     * @return87     */88    public WebServiceClientBuilder messageConverter(WebServiceMessageConverter messageConverter) {89        endpoint.getEndpointConfiguration().setMessageConverter(messageConverter);90        return this;91    }92    /**93     * Sets the interceptor.94     * @param interceptor95     * @return96     */97    public WebServiceClientBuilder interceptor(ClientInterceptor interceptor) {98        endpoint.getEndpointConfiguration().setInterceptor(interceptor);99        return this;100    }101    /**102     * Sets the interceptors.103     * @param interceptors104     * @return105     */106    public WebServiceClientBuilder interceptors(List<ClientInterceptor> interceptors) {107        endpoint.getEndpointConfiguration().setInterceptors(interceptors);108        return this;109    }110    /**111     * Sets the message correlator.112     * @param correlator113     * @return114     */115    public WebServiceClientBuilder correlator(MessageCorrelator correlator) {116        endpoint.getEndpointConfiguration().setCorrelator(correlator);117        return this;118    }119    /**120     * Sets the endpoint resolver.121     * @param resolver...

Source:WebServiceClientConfigParser.java

...25import com.consol.citrus.ws.message.converter.WebServiceMessageConverter;26import org.springframework.util.StringUtils;27import org.springframework.ws.WebServiceMessageFactory;28import org.springframework.ws.client.core.WebServiceTemplate;29import org.springframework.ws.client.support.interceptor.ClientInterceptor;30import org.springframework.ws.transport.WebServiceMessageSender;31/**32 * @author Christoph Deppisch33 * @since 2.534 */35public class WebServiceClientConfigParser extends AbstractAnnotationConfigParser<WebServiceClientConfig, WebServiceClient> {36    /**37     * Constructor matching super.38     * @param referenceResolver39     */40    public WebServiceClientConfigParser(ReferenceResolver referenceResolver) {41        super(referenceResolver);42    }43    @Override44    public WebServiceClient parse(WebServiceClientConfig annotation) {45        WebServiceClientBuilder builder = new WebServiceClientBuilder();46        builder.defaultUri(annotation.requestUrl());47        if (StringUtils.hasText(annotation.webServiceTemplate()) && (StringUtils.hasText(annotation.messageFactory()) ||48                StringUtils.hasText(annotation.messageSender()))) {49            throw new CitrusRuntimeException("When providing a 'web-service-template' reference, none of " +50                    "'message-factory', 'message-sender' should be set");51        }52        if (!StringUtils.hasText(annotation.requestUrl()) && !StringUtils.hasText(annotation.endpointResolver())) {53            throw new CitrusRuntimeException("One of the properties 'request-url' or 'endpoint-resolver' is required!");54        }55        if (StringUtils.hasText(annotation.webServiceTemplate())) {56            builder.webServiceTemplate(getReferenceResolver().resolve(annotation.webServiceTemplate(), WebServiceTemplate.class));57        }58        if (StringUtils.hasText(annotation.messageFactory())) {59            builder.messageFactory(getReferenceResolver().resolve(annotation.messageFactory(), WebServiceMessageFactory.class));60        } else {61            builder.messageFactory(getReferenceResolver().resolve("messageFactory", WebServiceMessageFactory.class));62        }63        if (StringUtils.hasText(annotation.messageSender())) {64            builder.messageSender(getReferenceResolver().resolve(annotation.messageSender(), WebServiceMessageSender.class));65        }66        if (StringUtils.hasText(annotation.messageConverter())) {67            builder.messageConverter(getReferenceResolver().resolve(annotation.messageConverter(), WebServiceMessageConverter.class));68        }69        builder.interceptors(getReferenceResolver().resolve(annotation.interceptors(), ClientInterceptor.class));70        if (StringUtils.hasText(annotation.interceptor())) {71            builder.interceptor(getReferenceResolver().resolve(annotation.interceptor(), ClientInterceptor.class));72        }73        if (StringUtils.hasText(annotation.correlator())) {74            builder.correlator(getReferenceResolver().resolve(annotation.correlator(), MessageCorrelator.class));75        }76        if (StringUtils.hasText(annotation.endpointResolver())) {77            builder.endpointResolver(getReferenceResolver().resolve(annotation.endpointResolver(), EndpointUriResolver.class));78        }79        builder.faultStrategy(annotation.faultStrategy());80        builder.pollingInterval(annotation.pollingInterval());81        builder.timeout(annotation.timeout());82        if (StringUtils.hasText(annotation.actor())) {83            builder.actor(getReferenceResolver().resolve(annotation.actor(), TestActor.class));84        }85        return builder.initialize().build();...

interceptor

Using AI Code Generation

1import com.consol.citrus.dsl.runner.TestRunner;2import com.consol.citrus.dsl.testng.TestNGCitrusTest;3import com.consol.citrus.ws.client.WebServiceClientBuilder;4import org.springframework.beans.factory.annotation.Autowired;5import org.springframework.beans.factory.annotation.Qualifier;6import org.testng.annotations.Test;7public class 3 extends TestNGCitrusTest {8    @Qualifier("client")9    private WebServiceClientBuilder client;10    public void test() {11        TestRunner runner = this.getRunner();12        runner.run(client.interceptor().handler(new com.consol.citrus.ws.interceptor.LoggingClientInterceptor()));13    }14}15import com.consol.citrus.dsl.runner.TestRunner;16import com.consol.citrus.dsl.testng.TestNGCitrusTest;17import com.consol.citrus.ws.client.WebServiceClientBuilder;18import org.springframework.beans.factory.annotation.Autowired;19import org.springframework.beans.factory.annotation.Qualifier;20import org.testng.annotations.Test;21public class 4 extends TestNGCitrusTest {22    @Qualifier("client")23    private WebServiceClientBuilder client;24    public void test() {25        TestRunner runner = this.getRunner();26        runner.run(client.interceptor().handler(new com.consol.citrus.ws.interceptor.LoggingClientInterceptor()));27    }28}29import com.consol.citrus.dsl.runner.TestRunner;30import com.consol.citrus.dsl.testng.TestNGCitrusTest;31import com.consol.citrus.ws.client.WebServiceClientBuilder;32import org.springframework.beans.factory.annotation.Autowired;33import org.springframework.beans.factory.annotation.Qualifier;34import org.testng.annotations.Test;35public class 5 extends TestNGCitrusTest {36    @Qualifier("client")37    private WebServiceClientBuilder client;38    public void test() {39        TestRunner runner = this.getRunner();40        runner.run(client.interceptor().handler(new com.consol.citrus.ws.interceptor.LoggingClientInterceptor()));41    }42}43import com.con

interceptor

Using AI Code Generation

1package com.consol.citrus.ws.client;2import javax.xml.namespace.QName;3import javax.xml.soap.SOAPMessage;4import org.springframework.ws.client.core.WebServiceMessageCallback;5import org.springframework.ws.soap.saaj.SaajSoapMessage;6import com.consol.citrus.ws.message.SoapAttachment;7public class WebServiceClientBuilderInterceptor implements WebServiceMessageCallback {8    public void doWithMessage(org.springframework.ws.soap.SoapMessage message) throws org.springframework.ws.WebServiceMessageException {9        SaajSoapMessage saajSoapMessage = (SaajSoapMessage) message;10        SOAPMessage soapMessage = saajSoapMessage.getSaajMessage();11        soapMessage.getSOAPHeader().removeAttribute("xmlns:wsa");12        soapMessage.getSOAPHeader().removeAttribute("xmlns:wsu");13        soapMessage.getSOAPHeader().removeAttribute("wsu:Id");14        soapMessage.getSOAPHeader().removeAttribute("wsa:Action");15        soapMessage.getSOAPHeader().removeAttribute("wsa:MessageID");16        soapMessage.getSOAPHeader().removeAttribute("wsa:To");17        soapMessage.getSOAPHeader().removeAttribute("wsa:RelatesTo");18        soapMessage.getSOAPHeader().removeAttribute("wsa:From");19        soapMessage.getSOAPHeader().removeAttribute("wsa:ReplyTo");20        soapMessage.getSOAPHeader().removeAttribute("wsa:FaultTo");21        soapMessage.getSOAPHeader().removeAttribute("wsa:EndpointReference");22        soapMessage.getSOAPHeader().removeAttribute("wsa:Address");23        soapMessage.getSOAPHeader().removeAttribute("wsa:ReferenceParameters");24        soapMessage.getSOAPHeader().removeAttribute("wsa:ReferenceProperties");25        soapMessage.getSOAPHeader().removeAttribute("wsa:PortType");26        soapMessage.getSOAPHeader().removeAttribute("wsa:ServiceName");27        soapMessage.getSOAPHeader().removeAttribute("wsa:InterfaceName");28        soapMessage.getSOAPHeader().removeAttribute("wsa:PortName");29        soapMessage.getSOAPHeader().removeAttribute("wsa:ServiceName");30        soapMessage.getSOAPHeader().removeAttribute("wsa:InterfaceName");31        soapMessage.getSOAPHeader().removeAttribute("wsa:PortName");32        soapMessage.getSOAPHeader().removeAttribute("wsa:Policy");33        soapMessage.getSOAPHeader().removeAttribute("wsa:Policy

interceptor

Using AI Code Generation

1package com.consol.citrus.ws.client;2import java.util.Collections;3import com.consol.citrus.ws.interceptor.LoggingClientInterceptor;4import org.springframework.ws.client.core.WebServiceTemplate;5import org.springframework.ws.soap.saaj.SaajSoapMessageFactory;6public class WebServiceClientBuilder {7    private WebServiceTemplate webServiceTemplate = new WebServiceTemplate();8    public WebServiceClientBuilder() {9        webServiceTemplate.setMessageFactory(new SaajSoapMessageFactory());10        webServiceTemplate.setInterceptors(Collections.singletonList(new LoggingClientInterceptor()));11    }12    public WebServiceClientBuilder messageFactory(SaajSoapMessageFactory messageFactory) {13        webServiceTemplate.setMessageFactory(messageFactory);14        return this;15    }16    public WebServiceClientBuilder defaultUri(String defaultUri) {17        webServiceTemplate.setDefaultUri(defaultUri);18        return this;19    }20    public WebServiceClientBuilder webServiceTemplate(WebServiceTemplate webServiceTemplate) {21        this.webServiceTemplate = webServiceTemplate;22        return this;23    }24    public WebServiceClient build() {25        return new WebServiceClient(webServiceTemplate);26    }27}28package com.consol.citrus.ws.client;29import com.consol.citrus.ws.interceptor.LoggingClientInterceptor;30import org.springframework.ws.client.core.WebServiceTemplate;31import org.springframework.ws.soap.saaj.SaajSoapMessageFactory;32public class WebServiceClientBuilder {33    private WebServiceTemplate webServiceTemplate = new WebServiceTemplate();34    public WebServiceClientBuilder() {35        webServiceTemplate.setMessageFactory(new SaajSoapMessageFactory());36        webServiceTemplate.setInterceptors(Collections.singletonList(new LoggingClientInterceptor()));37    }38    public WebServiceClientBuilder messageFactory(SaajSoapMessageFactory messageFactory) {39        webServiceTemplate.setMessageFactory(messageFactory);40        return this;41    }42    public WebServiceClientBuilder defaultUri(String defaultUri) {43        webServiceTemplate.setDefaultUri(defaultUri);44        return this;45    }46    public WebServiceClientBuilder webServiceTemplate(WebServiceTemplate webServiceTemplate) {47        this.webServiceTemplate = webServiceTemplate;48        return this;49    }50    public WebServiceClient build() {51        return new WebServiceClient(webServiceTemplate);52    }53}54package com.consol.citrus.ws.client;55import com.consol.citrus.ws.interceptor.LoggingClientInterceptor;56import org.springframework.ws.client.core.WebServiceTemplate;57import

interceptor

Using AI Code Generation

1public class WeatherClient extends WebServiceClientBuilder {2    public void configure() {3                + "<CityName>${city}</CityName>"4                + "<CountryName>${country}</CountryName>"5                + "</GetWeather>");6        send();7                + "<Temperature>${temperature}</Temperature>"8                + "<RelativeHumidity>${humidity}</RelativeHumidity>"9                + "<Pressure>${pressure}</Pressure>"10                + "<Speed>${windSpeed}</Speed>"11                + "<Direction>${windDirection}</Direction>"12                + "<Visibility>${visibility}</Visibility>"13                + "<DewPoint>${dewPoint}</DewPoint>"14                + "<WeatherStationCity>${stationCity}</WeatherStationCity>"15                + "<WeatherStationCountry>${stationCountry}</WeatherStationCountry>"16                + "<ObservationTime>${observationTime}</ObservationTime>"17                + "<Description>${description}</Description>"18                + "</GetWeatherResponse>");19    }20    public static void main(String[] args) {21        WeatherClient client = new WeatherClient();22        client.interceptor(new LoggingInterceptor());23        client.defaultVariables(new HashMap<String, Object>() {{24            put("city", "Frankfurt");25            put("country", "Germany");26            put("temperature", "10");27            put("humidity", "50");28            put("pressure", "1000");29            put("windSpeed", "10");30            put("windDirection", "N");31            put("visibility", "10");32            put("dewPoint", "10");33            put("stationCity", "Frankfurt");34            put("stationCountry", "Germany");35            put("observationTime", "10");36            put("description", "Sunny");37        }});38        client.send();39    }40}

interceptor

Using AI Code Generation

1@WebServiceClient(name = "example", wsdlLocation = "classpath:com/consol/citrus/wsdl/example.wsdl")2public class ExampleClient extends WebServiceGatewaySupport {3    private WebServiceClientBuilder webServiceClientBuilder;4    private MessageCorrelator messageCorrelator;5    private MessageStore messageStore;6    private MessageSelectorBuilder messageSelectorBuilder;7    public void sendRequest() {8        webServiceClientBuilder.interceptor(new ClientInterceptor() {9            public boolean handleRequest(MessageContext messageContext) throws WebServiceClientException {10                return true;11            }12            public boolean handleResponse(MessageContext messageContext) throws WebServiceClientException {13                return true;14            }15            public boolean handleFault(MessageContext messageContext) throws WebServiceClientException {16                return true;17            }18            public void afterCompletion(MessageContext messageContext, Exception ex) throws WebServiceClientException {19            }20        });21        webServiceClientBuilder.build();22    }23}24public void testWsClientInterceptor() {25    MockWebServiceClient mockClient = MockWebServiceClient.createClient(applicationContext);26        .andExpect(header("operation", "sayHello"))27        .andExpect(header("citrus_soap_action", "sayHello"))28        .andExpect(header("

interceptor

Using AI Code Generation

1public class WebServiceClient {2    @CitrusEndpointConfig(interceptor = "interceptor")3    private WebServiceClientBuilder webServiceClientBuilder;4    public WebServiceClientBuilder.WebServiceClientInterceptor interceptor() {5        return new WebServiceClientBuilder.WebServiceClientInterceptor() {6            public void intercept(WebServiceMessageCallback requestCallback, WebServiceMessageCallback responseCallback) {7            }8        };9    }10    public WebServiceClientBuilder.WebServiceClientInterceptor interceptor() {11        return new WebServiceClientBuilder.WebServiceClientInterceptor() {12            public void intercept(WebServiceMessageCallback requestCallback, WebServiceMessageCallback responseCallback) {13            }14        };15    }16    public WebServiceClientBuilder.WebServiceClientInterceptor interceptor() {17        return new WebServiceClientBuilder.WebServiceClientInterceptor() {18            public void intercept(WebServiceMessageCallback requestCallback, WebServiceMessageCallback responseCallback) {19            }20        };21    }22}23public class WebServiceClient {24    @CitrusEndpointConfig(interceptor = "interceptor")25    private WebServiceClientBuilder webServiceClientBuilder;26    public WebServiceClientBuilder.WebServiceClientInterceptor interceptor() {27        return new WebServiceClientBuilder.WebServiceClientInterceptor() {28            public void intercept(WebServiceMessageCallback requestCallback, WebServiceMessageCallback responseCallback) {29            }30        };31    }32}33public class WebServiceClient {34    @CitrusEndpointConfig(interceptor = "interceptor")35    private WebServiceClientBuilder webServiceClientBuilder;36    public WebServiceClientBuilder.WebServiceClientInterceptor interceptor() {

interceptor

Using AI Code Generation

1public void test() {2    given(webServiceClient().interceptor(new WebServiceMessageInterceptor() {3        public void handleRequest(WebServiceMessageContext messageContext) throws WebServiceClientInterceptorException {4            if (messageContext.getDirection() == WebServiceMessageContext.Direction.REQUEST) {5                try {6                    SoapMessage soapMessage = (SoapMessage) messageContext.getMessage();7                    soapMessage.setMtomEnabled(false);8                    soapMessage.setMtomEnabled(false);9                    soapMessage.setSoapVersion(SoapVersion.SOAP_12);10                    soapMessage.setMtomEnabled(false);11                    soapMessage.setSoapVersion(SoapVersion.SOAP_12);12                } catch (Exception e) {13                    throw new RuntimeException(e);14                }15            }16        }17    }))18        .when(webServiceClient().send()19        .then(webServiceClient().receive()20}21public void test() {22    given(webServiceClient().interceptors(new WebServiceMessageInterceptor[] { new WebServiceMessageInterceptor() {23        public void handleRequest(WebServiceMessageContext messageContext) throws WebServiceClientInterceptorException {24            if (messageContext.getDirection() == WebServiceMessageContext.Direction.REQUEST) {25                try {26                    SoapMessage soapMessage = (SoapMessage) messageContext.getMessage();27                    soapMessage.setMtomEnabled(false);28                    soapMessage.setMtomEnabled(false);29                    soapMessage.setSoapVersion(SoapVersion.SOAP_12);

interceptor

Using AI Code Generation

1public class 3 extends WebServiceClientBuilder {2    public void configure() {3        send()4                .header("Content-Type", "text/xml;charset=UTF-8")5                .header("Accept", "text/xml;charset=UTF-8")6                .header("Accept-Encoding", "gzip,deflate")7                .header("User-Agent", "Apache-HttpClient/4.1.1 (java 1.5)")8                .header("Host", "localhost:8080")9                .header("Connection", "Keep-Alive")10                .header("Content-Length", "130")11                .header("content-type", "text/xml;charset=UTF-8")12                .header("accept", "text/xml;charset=UTF-8")13                .header("accept-encoding", "gzip,deflate")14                .header("user-agent", "Apache-HttpClient/4.1.1 (java 1.5)")15                .header("host", "localhost:8080")16                .header("connection", "Keep-Alive")17                .header("content-length", "130")18                .header("content-type", "text/xml;charset=UTF-8")19                .header("accept", "text/xml;charset=UTF-8")20                .header("accept-encoding", "gzip,deflate")21                .header("user-agent", "Apache-HttpClient/4.1.1 (java 1.5)")22                .header("host", "localhost:8080")23                .header("connection", "Keep-Alive")24                .header("content-length", "130")25                .header("content-type", "text/xml;charset=UTF-8")

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.