You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2023/08/14 17:03:02 UTC
[camel] 02/02: CAMEL-19684: avoid a possible NPE getting the mock endpoint
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 <an...@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