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

Copied to Clipboard!

How to use ReceiveMessageBuilder method of com.consol.citrus.dsl.builder.ReceiveMessageBuilder class

Best Citrus code snippet using com.consol.citrus.dsl.builder.ReceiveMessageBuilder.ReceiveMessageBuilder

Source:WebHookToFtp_IT.java

1/*2 * Copyright (C) 2016 Red Hat, Inc.3 *4 * Licensed under the Apache License, Version 2.0 (the "License");5 * you may not use this file except in compliance with the License.6 * You may obtain a copy of the License at7 *8 *     http://www.apache.org/licenses/LICENSE-2.09 *10 * Unless required by applicable law or agreed to in writing, software11 * distributed under the License is distributed on an "AS IS" BASIS,12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.13 * See the License for the specific language governing permissions and14 * limitations under the License.15 */16package io.syndesis.test.itest.ftp;17import java.io.File;18import java.io.IOException;19import java.nio.file.Path;20import com.consol.citrus.actions.AbstractTestAction;21import com.consol.citrus.annotations.CitrusResource;22import com.consol.citrus.annotations.CitrusTest;23import com.consol.citrus.context.TestContext;24import com.consol.citrus.dsl.endpoint.CitrusEndpoints;25import com.consol.citrus.dsl.runner.TestRunner;26import com.consol.citrus.exceptions.CitrusRuntimeException;27import com.consol.citrus.ftp.message.FtpMessage;28import com.consol.citrus.http.client.HttpClient;29import com.consol.citrus.message.DefaultMessage;30import com.consol.citrus.util.FileUtils;31import com.consol.citrus.validation.json.JsonMessageValidationContext;32import com.consol.citrus.validation.json.JsonTextMessageValidator;33import io.syndesis.test.SyndesisTestEnvironment;34import io.syndesis.test.container.integration.SyndesisIntegrationRuntimeContainer;35import org.apache.commons.net.ftp.FTPCmd;36import org.apache.ftpserver.DataConnectionConfiguration;37import org.apache.ftpserver.DataConnectionConfigurationFactory;38import org.junit.Assert;39import org.junit.ClassRule;40import org.junit.Test;41import org.springframework.beans.factory.annotation.Autowired;42import org.springframework.context.annotation.Bean;43import org.springframework.context.annotation.Configuration;44import org.springframework.http.HttpStatus;45import org.springframework.test.annotation.DirtiesContext;46import org.springframework.test.context.ContextConfiguration;47import org.testcontainers.containers.GenericContainer;48/**49 * @author Christoph Deppisch50 */51@ContextConfiguration(classes = WebHookToFtp_IT.EndpointConfig.class)52@DirtiesContext53public class WebHookToFtp_IT extends FtpTestSupport {54    @Autowired55    private HttpClient webHookClient;56    /**57     * Integration receives a WebHook trigger with contact information as Json object. The contact is transformed to a csv like58     * comma delimited String and pushed to Ftp server as new file.59     */60    @ClassRule61    public static SyndesisIntegrationRuntimeContainer integrationContainer = new SyndesisIntegrationRuntimeContainer.Builder()62            .name("webhook-to-ftp")63            .fromExport(WebHookToFtp_IT.class.getResource("WebhookToFtp-export"))64            .customize("$..configuredProperties.contextPath", "contact")65            .customize("$..configuredProperties.directoryName", "public")66            .customize("$..configuredProperties.host", GenericContainer.INTERNAL_HOST_HOSTNAME)67            .customize("$..configuredProperties.port", FTP_TEST_SERVER_PORT)68            .build()69            .withExposedPorts(SyndesisTestEnvironment.getServerPort());70    @Test71    @CitrusTest72    public void testWebHookToFtp(@CitrusResource TestRunner runner) {73        runner.variable("first_name", "Joanne");74        runner.variable("company", "Red Hat");75        runner.variable("email", "joanne@syndesis.org");76        runner.http(builder -> builder.client(webHookClient)77                .send()78                .post()79                .fork(true)80                .payload("{\"first_name\":\"${first_name}\",\"company\":\"${company}\",\"mail\":\"${email}\"}"));81        runner.receive(receiveMessageBuilder -> receiveMessageBuilder82                .endpoint(ftpTestServer)83                .message(FtpMessage.command(FTPCmd.STOR).arguments("tmp_contacts.csv")));84        runner.send(sendMessageBuilder -> sendMessageBuilder85                .endpoint(ftpTestServer)86                .message(FtpMessage.success()));87        runner.receive(receiveMessageBuilder -> receiveMessageBuilder88                .endpoint(ftpTestServer)89                .message(FtpMessage.command(FTPCmd.RNFR).arguments("public/tmp_contacts.csv")));90        runner.send(sendMessageBuilder -> sendMessageBuilder91                .endpoint(ftpTestServer)92                .message(FtpMessage.success()));93        runner.http(builder -> builder.client(webHookClient)94                .receive()95                .response(HttpStatus.NO_CONTENT));96        runner.run(new VerifyFtpUploadTestAction());97    }98    @Configuration99    public static class EndpointConfig {100        @Bean101        public HttpClient webHookClient() {102            return CitrusEndpoints.http().client()103                    .requestUrl(String.format("http://localhost:%s/webhook/contact", integrationContainer.getServerPort()))104                    .build();105        }106        @Bean107        public DataConnectionConfiguration dataConnectionConfiguration() {108            DataConnectionConfigurationFactory dataConnectionFactory = new DataConnectionConfigurationFactory();109            dataConnectionFactory.setPassiveExternalAddress(integrationContainer.getInternalHostIp());110            dataConnectionFactory.setPassivePorts(String.valueOf(PASSIVE_PORT));111            return dataConnectionFactory.createDataConnectionConfiguration();112        }113    }114    /*115     * Helper test action ready the uploaded ftp file from user home directory and verifies116     * the content with Json message validator.117     */118    private static class VerifyFtpUploadTestAction extends AbstractTestAction {119        private static final String UPLOAD_FILENAME = "contacts.csv";120        @Override121        public void doExecute(TestContext testContext) {122            Path publicUserDir = getFtpUserHome().resolve("public");123            Assert.assertTrue( "Missing ftp user home directory", publicUserDir.toFile().exists());124            File ftpUploadFile = publicUserDir.resolve(UPLOAD_FILENAME).toFile();125            Assert.assertTrue(String.format("Missing ftp upload file '%s'", UPLOAD_FILENAME), ftpUploadFile.exists());126            try {127                JsonTextMessageValidator validator = new JsonTextMessageValidator();128                validator.validateMessage(new DefaultMessage(FileUtils.readToString(ftpUploadFile)),129                                            new DefaultMessage("{\"message\" : \"${first_name},${company},${email}\"}"),130                                            testContext,131                                            new JsonMessageValidationContext());132            } catch (IOException e) {133                throw new CitrusRuntimeException(String.format("Failed to verify ftp upload file '%s'", UPLOAD_FILENAME), e);134            }135        }136    }137}...

Source:ScenarioDesigner.java

...14 * limitations under the License.15 */16package com.consol.citrus.simulator.scenario;17import com.consol.citrus.context.TestContext;18import com.consol.citrus.dsl.builder.ReceiveMessageBuilder;19import com.consol.citrus.dsl.builder.SendMessageBuilder;20import com.consol.citrus.dsl.design.DefaultTestDesigner;21import com.consol.citrus.simulator.correlation.CorrelationHandlerBuilder;22import com.consol.citrus.simulator.correlation.CorrelationManager;23import com.consol.citrus.simulator.http.HttpScenarioActionBuilder;24import com.consol.citrus.simulator.ws.SoapScenarioActionBuilder;25import org.springframework.context.ApplicationContext;26/**27 * @author Christoph Deppisch28 */29public class ScenarioDesigner extends DefaultTestDesigner {30    /**31     * Scenario direct endpoint32     */33    private final ScenarioEndpoint scenarioEndpoint;34    /**35     * Default constructor using fields.36     *37     * @param scenarioEndpoint38     * @param applicationContext39     * @param context40     */41    public ScenarioDesigner(ScenarioEndpoint scenarioEndpoint, ApplicationContext applicationContext, TestContext context) {42        super(applicationContext, context);43        this.scenarioEndpoint = scenarioEndpoint;44    }45    /**46     * Start new message correlation so scenario is provided with additional inbound messages.47     *48     * @return49     */50    public CorrelationManager correlation() {51        return () -> {52            CorrelationHandlerBuilder builder = new CorrelationHandlerBuilder(scenarioEndpoint, getApplicationContext());53            action(builder);54            doFinally().actions(builder.stop());55            return builder;56        };57    }58    /**59     * Receive message from scenario endpoint.60     *61     * @return62     */63    public ReceiveMessageBuilder receive() {64        return (ReceiveMessageBuilder) receive(scenarioEndpoint)65                .description("Receive scenario request");66    }67    /**68     * Send message from scenario endpoint.69     *70     * @return71     */72    public SendMessageBuilder send() {73        return (SendMessageBuilder) send(scenarioEndpoint)74                .description("Send scenario response");75    }76    @Override77    public HttpScenarioActionBuilder http() {78        HttpScenarioActionBuilder builder = new HttpScenarioActionBuilder(scenarioEndpoint)...

ReceiveMessageBuilder

Using AI Code Generation

1package com.consol.citrus.dsl.builder;2import com.consol.citrus.actions.ReceiveMessageAction;3import com.consol.citrus.context.TestContext;4import com.consol.citrus.dsl.builder.ReceiveMessageBuilder;5import com.consol.citrus.dsl.builder.ReceiveMessageBuilderSupport;6import com.consol.citrus.dsl.builder.ReceiveTimeoutBuilder;7import com.consol.citrus.dsl.builder.ReceiveTimeoutBuilderSupport;8import com.consol.citrus.dsl.builder.TimeoutBuilder;9import com.consol.citrus.dsl.builder.TimeoutBuilderSupport;10import com.consol.citrus.message.Message;11import com.consol.citrus.message.MessageType;12import com.consol.citrus.messaging.Consumer;13import com.consol.citrus.validation.builder.PayloadTemplateMessageBuilder;14import com.consol.citrus.validation.builder.StaticMessageContentBuilder;15import com.consol.citrus.validation.json.JsonMessageValidationContext;16import com.consol.citrus.validation.xml.XmlMessageValidationContext;17import com.consol.citrus.validation.script.GroovyScriptMessageProcessor;18import com.consol.citrus.validation.script.GroovyScriptValidationContext;19import com.consol.citrus.validation.script.ScriptValidationContext;20import com.consol.citrus.validation.script.ScriptValidationContextBuilder;21import com.consol.citrus.validation.script.ScriptValidationContextBuilderSupport;22import com.consol.citrus.validation.script.ScriptValidationContextSupport;23import com.consol.citrus.validation.script.ScriptValidationProcessor;24import com.consol.citrus.validation.script.ScriptVali

ReceiveMessageBuilder

Using AI Code Generation

1package com.consol.citrus.dsl.design;2import com.consol.citrus.dsl.runner.TestRunner;3import com.consol.citrus.message.MessageType;4import com.consol.citrus.testng.AbstractTestNGCitrusTest;5import org.testng.annotations.Test;6public class ReceiveMessageBuilderTest extends AbstractTestNGCitrusTest {7public void receiveMessageBuilderTest() {8    TestRunner runner = new TestRunner(context);9    runner.receive(builder -> builder.endpoint("myEndpoint")10            .messageType(MessageType.PLAINTEXT)11            .message("Hello Citrus!")12            .timeout(5000L)13            .selector("operation = 'sayHello'")14            .header("operation", "sayHello")15            .header("citrus_jms_messageId", "1234567890")16            .payload("<TestRequestMessage><text>Hello Citrus!</text></TestRequestMessage>")17            .attachment("attachment1", "text/plain", "Hello Citrus!".getBytes())18            .attachment("attachment2", "text/plain", "Hello Citrus!".getBytes()));19    }20}21package com.consol.citrus.dsl.design;22import com.consol.citrus.dsl.runner.TestRunner;23import com.consol.citrus.message.MessageType;24import org.testng.annotations.Test;25import static com.consol.citrus.dsl.design.TestDesigner.receive;26public class ReceiveMessageBuilderTest extends AbstractTestNGCitrusTest {27public void receiveMessageBuilderTest() {28    TestRunner runner = new TestRunner(context);29    runner.receive(builder -> builder.endpoint("myEndpoint")30            .messageType(MessageType.PLAINTEXT)31            .message("Hello Citrus!")32            .timeout(5000L)33            .selector("operation = 'sayHello'")34            .header("operation", "sayHello")35            .header("citrus_jms_messageId", "1234567890")36            .payload("<TestRequestMessage><text>Hello Citrus!</text></TestRequestMessage>")37            .attachment("attachment1", "text/plain", "Hello Citrus!".getBytes())38            .attachment("attachment2", "text/plain", "Hello Citrus!".getBytes()));39    }40}

ReceiveMessageBuilder

Using AI Code Generation

1package com.consol.citrus.dsl.builder;2import org.springframework.beans.factory.annotation.Autowired;3import org.springframework.beans.factory.annotation.Qualifier;4import org.springframework.context.ApplicationContext;5import org.springframework.context.ConfigurableApplicationContext;6import org.springframework.context.support.ClassPathXmlApplicationContext;7import org.springframework.integration.Message;8import org.springframework.integration.support.MessageBuilder;9import org.springframework.integration.test.context.SpringIntegrationTest;10import org.springframework.test.context.ContextConfiguration;11import org.springframework.test.context.testng.AbstractTestNGSpringContextTests;12import org.testng.annotations.Test;13import com.consol.citrus.annotations.CitrusTest;14import com.consol.citrus.dsl.builder.ReceiveMessageBuilder;15import com.consol.citrus.dsl.testng.TestNGCitrusTestRunner;16import com.consol.citrus.message.MessageType;17import com.consol.citrus.testng.CitrusParameters;18import com.consol.citrus.validation.builder.DefaultMessageBuilder;19import com.consol.citrus.validation.json.JsonMessageValidationContext;20import com.consol.citrus.validation.xml.XpathMessageValidationContext;21import com.consol.citrus.ws.client.WebServiceClient;22import com.consol.citrus.ws.message.SoapAttachment;23import com.consol.citrus.ws.message.SoapMessage;24import com.consol.citrus.ws.message.SoapMessageHeaders;25import com.consol.citrus.ws.validation.SoapAttachmentValidationContext;26import com.consol.citrus.ws.validation.SoapMessageValidationContext;27import static com.consol.citrus.actions.ReceiveMessageAction.Builder.receive;28import static com.consol.citrus.actions.SendMessageAction.Builder.send;29import static com.consol.citrus.container.Sequence.Builder.sequential;30import static com.consol.citrus.container.Assert.Builder.assertException;31import static com.consol.citrus.dsl.builder.BuilderSupport.variable;32import static com.consol.citrus.dsl.builder.BuilderSupport.xpath;33import static com.consol.citrus.dsl.builder.BuilderSupport.jsonPath;34import static com.consol.citrus.dsl.builder.BuilderSupport.jsonPathValueExtractor;35import static com.consol.citrus.dsl.builder.BuilderSupport.xpathValueExtractor;36import static com.consol.citrus.dsl.builder.BuilderSupport.header;37import static com.consol.citrus.dsl.builder.BuilderSupport.attachment;38import static com.consol.citrus.dsl.builder.BuilderSupport.message;39import static com.consol.citrus.dsl.builder.BuilderSupport.payload;40import static com.consol.citrus.dsl.builder.BuilderSupport.messageType

ReceiveMessageBuilder

Using AI Code Generation

1package com.consol.citrus.dsl.builder;2import com.consol.citrus.dsl.builder.ReceiveMessageBuilder;3import com.consol.citrus.dsl.builder.ReceiveMessageBuilderSupport;4import org.springframework.util.StringUtils;5import org.springframework.ws.client.core.WebServiceTemplate;6import org.springframework.ws.soap.SoapMessage;

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.