This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit b2c0b5c896bace1448de40d809aa98b824c523bd Author: Otavio Rodolfo Piske <angusyo...@gmail.com> AuthorDate: Mon Aug 14 17:02:07 2023 +0200 CAMEL-19684: avoid a possible NPE getting the mock endpoint --- .../org/apache/camel/component/rocketmq/RocketMQRouteTest.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/components/camel-rocketmq/src/test/java/org/apache/camel/component/rocketmq/RocketMQRouteTest.java b/components/camel-rocketmq/src/test/java/org/apache/camel/component/rocketmq/RocketMQRouteTest.java index ea7745fd751..78d090b336a 100644 --- a/components/camel-rocketmq/src/test/java/org/apache/camel/component/rocketmq/RocketMQRouteTest.java +++ b/components/camel-rocketmq/src/test/java/org/apache/camel/component/rocketmq/RocketMQRouteTest.java @@ -18,10 +18,12 @@ package org.apache.camel.component.rocketmq; import java.io.IOException; +import java.time.Duration; import org.apache.camel.CamelContext; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.mock.MockEndpoint; +import org.awaitility.Awaitility; import org.junit.jupiter.api.AfterAll; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; @@ -46,7 +48,7 @@ public class RocketMQRouteTest extends RocketMQTestSupport { @BeforeEach public void setUp() throws Exception { super.setUp(); - resultEndpoint = (MockEndpoint) context.getEndpoint(RESULT_ENDPOINT_URI); + } @Override @@ -54,6 +56,7 @@ public class RocketMQRouteTest extends RocketMQTestSupport { CamelContext camelContext = super.createCamelContext(); RocketMQComponent rocketMQComponent = new RocketMQComponent(); rocketMQComponent.setNamesrvAddr(rocketMQService.nameserverAddress()); + camelContext.addComponent("rocketmq", rocketMQComponent); return camelContext; } @@ -71,13 +74,14 @@ public class RocketMQRouteTest extends RocketMQTestSupport { @Test public void testSimpleRoute() throws Exception { + resultEndpoint = (MockEndpoint) context.getEndpoint(RESULT_ENDPOINT_URI); resultEndpoint.expectedBodiesReceived(EXPECTED_MESSAGE); resultEndpoint.message(0).header(RocketMQConstants.TOPIC).isEqualTo("START_TOPIC"); resultEndpoint.message(0).header(RocketMQConstants.TAG).isEqualTo("startTag"); template.sendBody(START_ENDPOINT_URI, EXPECTED_MESSAGE); - resultEndpoint.assertIsSatisfied(); + Awaitility.await().atMost(Duration.ofSeconds(5)).untilAsserted(() -> resultEndpoint.assertIsSatisfied()); } @AfterAll