How to use execute method of com.consol.citrus.dsl.runner.ReceiveHttpMessageTestRunnerTest class

Best Citrus code snippet using com.consol.citrus.dsl.runner.ReceiveHttpMessageTestRunnerTest.execute

Source:ReceiveHttpMessageTestRunnerTest.java

...58                .queryParam("param1", "value1")59                .queryParam("param2", "value2"));60        MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {61            @Override62            public void execute() {63                http(action -> action.server(httpServer)64                        .receive()65                        .get("/test/foo")66                        .queryParam("noValue", null)67                        .queryParam("param1", "value1")68                        .queryParam("param2", "value2")69                        .payload("<TestRequest><Message>Hello World!</Message></TestRequest>"));70            }71        };72        TestCase test = builder.getTestCase();73        Assert.assertEquals(test.getActionCount(), 1);74        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), ReceiveMessageAction.class);75        ReceiveMessageAction action = (ReceiveMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();76        Assert.assertEquals(action.getName(), "receive");77        Assert.assertEquals(action.getEndpoint(), httpServer);78        Assert.assertEquals(action.getValidationContexts().size(), 3L);79        Assert.assertEquals(action.getValidationContexts().get(0).getClass(), HeaderValidationContext.class);80        Assert.assertEquals(action.getValidationContexts().get(1).getClass(), XmlMessageValidationContext.class);81        Assert.assertEquals(action.getValidationContexts().get(2).getClass(), JsonMessageValidationContext.class);82        HttpMessageContentBuilder messageBuilder = (HttpMessageContentBuilder) action.getMessageBuilder();83        Assert.assertEquals(messageBuilder.getMessage().getPayload(), "<TestRequest><Message>Hello World!</Message></TestRequest>");84        Assert.assertEquals(messageBuilder.getMessage().getHeaders().size(), 7L);85        Assert.assertEquals(messageBuilder.getMessage().getHeaders().get(HttpMessageHeaders.HTTP_REQUEST_METHOD), HttpMethod.GET.name());86        Assert.assertEquals(messageBuilder.getMessage().getHeaders().get(HttpMessageHeaders.HTTP_REQUEST_URI), "/test/foo");87        Assert.assertEquals(messageBuilder.getMessage().getHeaders().get(HttpMessageHeaders.HTTP_QUERY_PARAMS), "noValue,param1=value1,param2=value2");88    }89    @Test90    public void testMessageObjectOverride() {91        reset(httpServer, messageConsumer, configuration);92        when(httpServer.createConsumer()).thenReturn(messageConsumer);93        when(httpServer.getEndpointConfiguration()).thenReturn(configuration);94        when(configuration.getTimeout()).thenReturn(100L);95        when(httpServer.getActor()).thenReturn(null);96        when(messageConsumer.receive(any(TestContext.class), anyLong())).thenReturn(new HttpMessage("<TestRequest><Message>Hello World!</Message></TestRequest>")97                .method(HttpMethod.GET)98                .path("/test/foo")99                .header("X-Foo", "foo")100                .header("X-Bar", "bar")101                .contentType(ContentType.APPLICATION_XML.getMimeType())102                .queryParam("param1", "value1"));103        MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {104            @Override105            public void execute() {106                http(action -> action.server(httpServer)107                        .receive()108                        .get("/test/foo")109                        .queryParam("param1", "value1")110                        .contentType(ContentType.APPLICATION_XML.getMimeType())111                        .header("X-Bar", "bar")112                        .message(new HttpMessage("<TestRequest><Message>Hello World!</Message></TestRequest>")).header("X-Foo", "foo"));113            }114        };115        TestCase test = builder.getTestCase();116        Assert.assertEquals(test.getActionCount(), 1);117        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), ReceiveMessageAction.class);118        ReceiveMessageAction action = (ReceiveMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();119        Assert.assertEquals(action.getName(), "receive");120        Assert.assertEquals(action.getEndpoint(), httpServer);121        Assert.assertEquals(action.getValidationContexts().size(), 3L);122        Assert.assertEquals(action.getValidationContexts().get(0).getClass(), HeaderValidationContext.class);123        Assert.assertEquals(action.getValidationContexts().get(1).getClass(), XmlMessageValidationContext.class);124        Assert.assertEquals(action.getValidationContexts().get(2).getClass(), JsonMessageValidationContext.class);125        HttpMessageContentBuilder messageBuilder = (HttpMessageContentBuilder) action.getMessageBuilder();126        Assert.assertEquals(messageBuilder.getMessage().getPayload(), "<TestRequest><Message>Hello World!</Message></TestRequest>");127        Assert.assertEquals(messageBuilder.getMessage().getHeaders().size(), 10L);128        Assert.assertNotNull(messageBuilder.getMessage().getHeader(MessageHeaders.ID));129        Assert.assertNotNull(messageBuilder.getMessage().getHeader(MessageHeaders.TIMESTAMP));130        Assert.assertEquals(messageBuilder.getMessage().getHeaders().get(HttpMessageHeaders.HTTP_REQUEST_METHOD), HttpMethod.GET.name());131        Assert.assertEquals(messageBuilder.getMessage().getHeaders().get(HttpMessageHeaders.HTTP_REQUEST_URI), "/test/foo");132        Assert.assertEquals(messageBuilder.getMessage().getHeaders().get(DynamicEndpointUriResolver.REQUEST_PATH_HEADER_NAME), "/test/foo");133        Assert.assertEquals(messageBuilder.getMessage().getHeaders().get(HttpMessageHeaders.HTTP_QUERY_PARAMS), "param1=value1");134        Assert.assertEquals(messageBuilder.getMessage().getHeaders().get(DynamicEndpointUriResolver.QUERY_PARAM_HEADER_NAME), "param1=value1");135        Assert.assertEquals(messageBuilder.getMessage().getHeaders().get(HttpMessageHeaders.HTTP_CONTENT_TYPE), ContentType.APPLICATION_XML.getMimeType());136        Assert.assertEquals(messageBuilder.getMessage().getHeaders().get("X-Foo"), "foo");137        Assert.assertEquals(messageBuilder.getMessage().getHeaders().get("X-Bar"), "bar");138    }139    @Test140    public void testHttpResponseProperties() {141        reset(httpClient, messageConsumer, configuration);142        when(httpClient.createConsumer()).thenReturn(messageConsumer);143        when(httpClient.getEndpointConfiguration()).thenReturn(configuration);144        when(configuration.getTimeout()).thenReturn(100L);145        when(httpClient.getActor()).thenReturn(null);146        when(messageConsumer.receive(any(TestContext.class), anyLong())).thenReturn(new HttpMessage("<TestRequest><Message>Hello World!</Message></TestRequest>")147                .method(HttpMethod.GET)148                .uri("/test")149                .status(HttpStatus.OK)150                .version("HTTP/1.1"));151        MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {152            @Override153            public void execute() {154                http(action -> action.client(httpClient)155                        .receive()156                        .response(HttpStatus.OK)157                        .version("HTTP/1.1")158                        .payload("<TestRequest><Message>Hello World!</Message></TestRequest>"));159            }160        };161        TestCase test = builder.getTestCase();162        Assert.assertEquals(test.getActionCount(), 1);163        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), ReceiveMessageAction.class);164        ReceiveMessageAction action = (ReceiveMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();165        Assert.assertEquals(action.getName(), "receive");166        Assert.assertEquals(action.getEndpoint(), httpClient);167        Assert.assertEquals(action.getValidationContexts().size(), 3L);...

execute

Using AI Code Generation

1import org.springframework.http.HttpStatus;2import org.springframework.http.MediaType;3import org.testng.annotations.Test;4import com.consol.citrus.annotations.CitrusTest;5import com.consol.citrus.dsl.builder.HttpActionBuilder;6import com.consol.citrus.dsl.runner.TestRunner;7import com.consol.citrus.http.client.HttpClient;8import com.consol.citrus.testng.AbstractTestNGCitrusTest;9public class ReceiveHttpMessageTestRunnerTest extends AbstractTestNGCitrusTest {10    public void receiveHttpMessageTestRunnerTest(TestRunner runner) {11        runner.http(httpActionBuilder -> httpActionBuilder.client(httpClient())12                .send()13                .post("/test")14                .contentType(MediaType.APPLICATION_JSON_VALUE)15                .payload("{\"name\": \"citrus\"}"));16        runner.http(httpActionBuilder -> httpActionBuilder.client(httpClient())17                .receive()18                .response(HttpStatus.OK)19                .messageType(MessageType.JSON)20                .payload("{\"name\": \"citrus\"}"));21    }22    public void receiveHttpMessageJavaDSLTest() {23        HttpClient client = httpClient();24        send(client)25            .post("/test")26            .contentType(MediaType.APPLICATION_JSON_VALUE)27            .payload("{\"name\": \"citrus\"}");28        receive(client)29            .response(HttpStatus.OK)30            .messageType(MessageType.JSON)31            .payload("{\"name\": \"citrus\"}");32    }33    private HttpActionBuilder.HttpSendActionBuilder send(HttpClient client) {34        return new HttpActionBuilder.SendHttpMessageActionBuilder()35                .client(client)36                .send();37    }38    private HttpActionBuilder.HttpReceiveActionBuilder receive(HttpClient client) {39        return new HttpActionBuilder.ReceiveHttpMessageActionBuilder()40                .client(client)41                .receive();42    }43    private HttpClient httpClient() {44        return CitrusEndpoints.http()45                .client()46                .build();47    }48}

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.