iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

https://jira.baeldung.com/browse/BAEL-5235

Browse Source
This commit is contained in:
michaelin007 2024-02-07 07:01:48 +00:00
parent f63fbeca4f
commit 8af3dd780f
2 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apache-libraries-2/src/main/java/com/baeldung/dynamicrouter/DynamicRouterBean.java
View File

@ -20,8 +20,8 @@ public class DynamicRouterBean {
return "mock:directDynamicRouter"; return "mock:directDynamicRouter";
} else if (body.equalsIgnoreCase("seda") && invoked == 1) { } else if (body.equalsIgnoreCase("seda") && invoked == 1) {
return "mock:sedaDynamicRouter"; return "mock:sedaDynamicRouter";
} else if (body.equalsIgnoreCase("book") && invoked == 1) { } else if (body.equalsIgnoreCase("file") && invoked == 1) {
return "mock:bookDynamicRouter"; return "mock:fileDynamicRouter";
} }
return null; return null;
} }

6
apache-libraries-2/src/test/java/dynamicrouter/DynamicRouterRouteUnitTest.java
View File

@ -21,7 +21,6 @@ public class DynamicRouterRouteUnitTest extends CamelTestSupport {
template.send("direct:dynamicRouter", exchange -> exchange.getIn() template.send("direct:dynamicRouter", exchange -> exchange.getIn()
.setBody("mock")); .setBody("mock"));
context.start();
MockEndpoint.assertIsSatisfied(context); MockEndpoint.assertIsSatisfied(context);
} }
@ -45,18 +44,17 @@ public class DynamicRouterRouteUnitTest extends CamelTestSupport {
template.send("direct:dynamicRouter", exchange -> exchange.getIn() template.send("direct:dynamicRouter", exchange -> exchange.getIn()
.setBody("seda")); .setBody("seda"));
MockEndpoint.assertIsSatisfied(context); MockEndpoint.assertIsSatisfied(context);
} }
@Test @Test
void givenDynamicRouter_whenMockEndpointExpectedMessageCountOneAndBookAsMessageBody_thenMessageSentToDynamicRouter() throws InterruptedException { void givenDynamicRouter_whenMockEndpointExpectedMessageCountOneAndBookAsMessageBody_thenMessageSentToDynamicRouter() throws InterruptedException {
MockEndpoint mockDynamicEndpoint = getMockEndpoint("mock:bookDynamicRouter"); MockEndpoint mockDynamicEndpoint = getMockEndpoint("mock:fileDynamicRouter");
mockDynamicEndpoint.expectedMessageCount(1); mockDynamicEndpoint.expectedMessageCount(1);
template.send("direct:dynamicRouter", exchange -> exchange.getIn() template.send("direct:dynamicRouter", exchange -> exchange.getIn()
.setBody("book")); .setBody("file"));
MockEndpoint.assertIsSatisfied(context); MockEndpoint.assertIsSatisfied(context);
} }