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 3754ad86388d1c2181e9ad27db0cac31080cd446 Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Thu May 30 10:54:17 2024 +0200 (chores) camel-rocketmq: cleanup getting the mock endpoints --- .../apache/camel/component/rocketmq/RocketMQRequestReplyRouteIT.java | 4 +--- .../java/org/apache/camel/component/rocketmq/RocketMQRouteIT.java | 4 +--- 2 files changed, 2 insertions(+), 6 deletions(-) diff --git a/components/camel-rocketmq/src/test/java/org/apache/camel/component/rocketmq/RocketMQRequestReplyRouteIT.java b/components/camel-rocketmq/src/test/java/org/apache/camel/component/rocketmq/RocketMQRequestReplyRouteIT.java index eb9ec64648f..c4fe099f849 100644 --- a/components/camel-rocketmq/src/test/java/org/apache/camel/component/rocketmq/RocketMQRequestReplyRouteIT.java +++ b/components/camel-rocketmq/src/test/java/org/apache/camel/component/rocketmq/RocketMQRequestReplyRouteIT.java @@ -56,8 +56,6 @@ public class RocketMQRequestReplyRouteIT extends RocketMQTestSupport { private static final int MESSAGE_COUNT = 5; - private MockEndpoint resultEndpoint; - private DefaultMQPushConsumer replierConsumer; private DefaultMQProducer replierProducer; @@ -73,7 +71,6 @@ public class RocketMQRequestReplyRouteIT extends RocketMQTestSupport { @BeforeEach public void setUp() throws Exception { super.setUp(); - resultEndpoint = (MockEndpoint) context.getEndpoint(RESULT_ENDPOINT_URI); replierProducer = new DefaultMQProducer("replierProducer"); replierProducer.setNamesrvAddr(rocketMQService.nameserverAddress()); replierProducer.start(); @@ -118,6 +115,7 @@ public class RocketMQRequestReplyRouteIT extends RocketMQTestSupport { @Test public void testRouteMessageInRequestReplyMode() throws Exception { + MockEndpoint resultEndpoint = getMockEndpoint(RESULT_ENDPOINT_URI); resultEndpoint.expectedBodiesReceived(EXPECTED_MESSAGE); resultEndpoint.message(0).header(RocketMQConstants.TOPIC).isEqualTo("REPLY_TO_TOPIC"); diff --git a/components/camel-rocketmq/src/test/java/org/apache/camel/component/rocketmq/RocketMQRouteIT.java b/components/camel-rocketmq/src/test/java/org/apache/camel/component/rocketmq/RocketMQRouteIT.java index 9cede0d4ccb..a19ee11e399 100644 --- a/components/camel-rocketmq/src/test/java/org/apache/camel/component/rocketmq/RocketMQRouteIT.java +++ b/components/camel-rocketmq/src/test/java/org/apache/camel/component/rocketmq/RocketMQRouteIT.java @@ -43,8 +43,6 @@ public class RocketMQRouteIT extends RocketMQTestSupport { private static final int MESSAGE_COUNT = 5; - private MockEndpoint resultEndpoint; - private CountDownLatch latch = new CountDownLatch(MESSAGE_COUNT); @BeforeAll @@ -84,7 +82,7 @@ public class RocketMQRouteIT extends RocketMQTestSupport { @Test public void testSimpleRoute() throws Exception { - resultEndpoint = (MockEndpoint) context.getEndpoint(RESULT_ENDPOINT_URI); + MockEndpoint resultEndpoint = getMockEndpoint(RESULT_ENDPOINT_URI); resultEndpoint.expectedBodiesReceived(EXPECTED_MESSAGE); resultEndpoint.message(0).header(RocketMQConstants.TOPIC).isEqualTo("START_TOPIC"); resultEndpoint.message(0).header(RocketMQConstants.TAG).isEqualTo("startTag");
