How to use InternalFaultMessageResolver method of com.consol.citrus.ws.client.WebServiceClient class

Best Citrus code snippet using com.consol.citrus.ws.client.WebServiceClient.InternalFaultMessageResolver

Source:WebServiceClient.java

...98                    "' Currently only 'java.lang.String' is supported as payload type.");99        }100        SoapRequestMessageCallback requestCallback = new SoapRequestMessageCallback(soapMessage, getEndpointConfiguration(), context);101        SoapResponseMessageCallback responseCallback = new SoapResponseMessageCallback(getEndpointConfiguration(), context);102        getEndpointConfiguration().getWebServiceTemplate().setFaultMessageResolver(new InternalFaultMessageResolver(correlationKey, endpointUri, context));103        boolean result;104        // send and receive message105        if (getEndpointConfiguration().getEndpointResolver() != null) {106            result = getEndpointConfiguration().getWebServiceTemplate().sendAndReceive(endpointUri, requestCallback, responseCallback);107        } else { // use default endpoint uri108            result = getEndpointConfiguration().getWebServiceTemplate().sendAndReceive(requestCallback, responseCallback);109        }110        log.info("SOAP message was sent to endpoint: '" + endpointUri + "'");111        if (result) {112            log.info("Received SOAP response on endpoint: '" + endpointUri + "'");113            correlationManager.store(correlationKey, responseCallback.getResponse());114        } else {115            log.info("Received no SOAP response from endpoint: '" + endpointUri + "'");116        }117    }118    @Override119    public Message receive(TestContext context) {120        return receive(correlationManager.getCorrelationKey(121                getEndpointConfiguration().getCorrelator().getCorrelationKeyName(getName()), context), context);122    }123    @Override124    public Message receive(String selector, TestContext context) {125        return receive(selector, context, getEndpointConfiguration().getTimeout());126    }127    @Override128    public Message receive(TestContext context, long timeout) {129        return receive(correlationManager.getCorrelationKey(130                getEndpointConfiguration().getCorrelator().getCorrelationKeyName(getName()), context), context, timeout);131    }132    @Override133    public Message receive(String selector, TestContext context, long timeout) {134        Message message = correlationManager.find(selector, timeout);135        if (message == null) {136            throw new ActionTimeoutException("Action timeout while receiving synchronous reply message from soap web server");137        }138        return message;139    }140    /**141     * Creates a message producer for this endpoint for sending messages142     * to this endpoint.143     */144    @Override145    public Producer createProducer() {146        return this;147    }148    /**149     * Creates a message consumer for this endpoint. Consumer receives150     * messages on this endpoint.151     *152     * @return153     */154    @Override155    public SelectiveConsumer createConsumer() {156        return this;157    }158    /**159     * Handles error response messages constructing a proper response message160     * which will be propagated to the respective endpoint consumer for161     * further processing.162     */163    private class InternalFaultMessageResolver implements FaultMessageResolver {164        /** Request message associated with this response error handler */165        private String correlationKey;166        /** The endpoint that was initially invoked */167        private String endpointUri;168        /** Test context */169        private TestContext context;170        /**171         * Default constructor provided with request message172         * associated with this fault resolver and endpoint uri.173         */174        public InternalFaultMessageResolver(String correlationKey, String endpointUri, TestContext context) {175            this.correlationKey = correlationKey;176            this.endpointUri = endpointUri;177            this.context = context;178        }179        /**180         * Handle fault response message according to error strategy.181         */182        public void resolveFault(WebServiceMessage webServiceResponse) throws IOException {183            if (getEndpointConfiguration().getErrorHandlingStrategy().equals(ErrorHandlingStrategy.PROPAGATE)) {184                SoapResponseMessageCallback callback = new SoapResponseMessageCallback(getEndpointConfiguration(), context);185                try {186                    callback.doWithMessage(webServiceResponse);187                    Message responseMessage = callback.getResponse();188                    if (webServiceResponse instanceof org.springframework.ws.soap.SoapMessage) {...

InternalFaultMessageResolver

Using AI Code Generation

1public class InternalFaultMessageResolver extends AbstractFaultMessageResolver {2    public boolean supportsFault(SoapFault fault) {3        return true;4    }5    public void resolveFault(SoapFault fault) {6        throw new CitrusRuntimeException("Internal server error: " + fault.getFaultStringOrReason());7    }8}9public WebServiceClient client() {10    WebServiceClient client = new WebServiceClient();11    client.setFaultMessageResolver(internalFaultMessageResolver());12    return client;13}14public InternalFaultMessageResolver internalFaultMessageResolver() {15    return new InternalFaultMessageResolver();16}17public WebServiceClient client() {18    WebServiceClient client = new WebServiceClient();19    client.setFaultMessageResolver(internalFaultMessageResolver());20    return client;21}22public InternalFaultMessageResolver internalFaultMessageResolver() {23    return new InternalFaultMessageResolver();24}

InternalFaultMessageResolver

Using AI Code Generation

1class InternalFaultMessageResolver implements FaultMessageResolver {2    public String resolveFaultMessage(WebServiceClient client, WebServiceEndpointConfiguration endpointConfiguration, SoapFaultDetail faultDetail) {3        return client.resolveFaultMessage(faultDetail.getFaultString());4    }5}6class InternalFaultMessageResolver implements FaultMessageResolver {7    public String resolveFaultMessage(WebServiceClient client, WebServiceEndpointConfiguration endpointConfiguration, SoapFaultDetail faultDetail) {8        return client.resolveFaultMessage(faultDetail.getFaultString());9    }10}11class InternalFaultMessageResolver implements FaultMessageResolver {12    public String resolveFaultMessage(WebServiceClient client, WebServiceEndpointConfiguration endpointConfiguration, SoapFaultDetail faultDetail) {13        return client.resolveFaultMessage(faultDetail.getFaultString());14    }15}16class InternalFaultMessageResolver implements FaultMessageResolver {17    public String resolveFaultMessage(WebServiceClient client, WebServiceEndpointConfiguration endpointConfiguration, SoapFaultDetail faultDetail) {18        return client.resolveFaultMessage(faultDetail.getFaultString());19    }20}21class InternalFaultMessageResolver implements FaultMessageResolver {22    public String resolveFaultMessage(WebServiceClient client, WebServiceEndpointConfiguration endpointConfiguration, SoapFaultDetail faultDetail) {23        return client.resolveFaultMessage(faultDetail.getFaultString());24    }25}26class InternalFaultMessageResolver implements FaultMessageResolver {27    public String resolveFaultMessage(WebServiceClient client, WebServiceEndpointConfiguration endpointConfiguration, SoapFaultDetail faultDetail) {28        return client.resolveFaultMessage(faultDetail.getFaultString());29    }30}

InternalFaultMessageResolver

Using AI Code Generation

1public class CitrusTest extends TestNGCitrusTestDesigner {2    public void test() {3        http().client("httpClient")4                .send()5                .post("/citrus-ws-2.7.4/services/HelloService")6                .contentType("text/xml")7                        "</soapenv:Envelope>");8        http().client("httpClient")9                .receive()10                .response(HttpStatus.BAD_REQUEST)11                        "</soapenv:Envelope>");12        http().client("httpClient")13                .send()14                .post("/citrus-ws-2.7.4/services/HelloService")15                .contentType("text/xml")

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.