apache-libraries-2/src/test/java/com/baeldung/apache/camel/DynamicRouterRouteUnitTest.java - master - NikolayIvkin/tutorials1

apache-libraries-2/src/test/java/com/baeldung/apache/camel/DynamicRouterRouteUnitTest.java

61 строка2 KB

Gaetano Piazzolla

[JAVA-38868] Move apache-lib (#17447)

28 авг 2024, 20:25

28 авг 2024, 20:25a6ce976

package com.baeldung.apache.camel;

import com.baeldung.apache.camel.DynamicRouterRoute;
import org.apache.camel.RoutesBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Test;

public class DynamicRouterRouteUnitTest extends CamelTestSupport {

    @Override
    protected RoutesBuilder createRouteBuilder() {
        return new DynamicRouterRoute();
    }

    @Test
    void givenDynamicRouter_whenMockEndpointExpectedMessageCountOneAndMockAsMessageBody_thenMessageSentToDynamicRouter() throws InterruptedException {

        MockEndpoint mockDynamicEndpoint = getMockEndpoint("mock:dynamicRouter");
        mockDynamicEndpoint.expectedMessageCount(1);

        template.send("direct:dynamicRouter", exchange -> exchange.getIn()
            .setBody("mock"));
        MockEndpoint.assertIsSatisfied(context);
    }

    @Test
    void givenDynamicRouter_whenMockEndpointExpectedMessageCountOneAndDirectAsMessageBody_thenMessageSentToDynamicRouter() throws InterruptedException {

        MockEndpoint mockDynamicEndpoint = context.getEndpoint("mock:directDynamicRouter", MockEndpoint.class);
        mockDynamicEndpoint.expectedMessageCount(1);

        template.send("direct:dynamicRouter", exchange -> exchange.getIn()
            .setBody("direct"));

        MockEndpoint.assertIsSatisfied(context);
    }

    @Test
    void givenDynamicRouter_whenMockEndpointExpectedMessageCountOneAndSedaAsMessageBody_thenMessageSentToDynamicRouter() throws InterruptedException {

        MockEndpoint mockDynamicEndpoint = context.getEndpoint("mock:sedaDynamicRouter", MockEndpoint.class);
        mockDynamicEndpoint.expectedMessageCount(1);

        template.send("direct:dynamicRouter", exchange -> exchange.getIn()
            .setBody("seda"));
        MockEndpoint.assertIsSatisfied(context);
    }

    @Test
    void givenDynamicRouter_whenMockEndpointExpectedMessageCountOneAndBookAsMessageBody_thenMessageSentToDynamicRouter() throws InterruptedException {

        MockEndpoint mockDynamicEndpoint = getMockEndpoint("mock:fileDynamicRouter");
        mockDynamicEndpoint.expectedMessageCount(1);

        template.send("direct:dynamicRouter", exchange -> exchange.getIn()
            .setBody("file"));
        MockEndpoint.assertIsSatisfied(context);
    }

}