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 2024/03/18 19:25:58 UTC
(camel) 05/08: CAMEL-20477: try to fix flakiness on JmsInOutRoutingSlipTest
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 a376bc9148331f5fc8454792502ce4e930e7546b
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Mon Mar 18 10:17:28 2024 +0100
CAMEL-20477: try to fix flakiness on JmsInOutRoutingSlipTest
- Setup mocks in advance
- Use a transient extension to allow repeating the test and ensure a clean test context
- Repeat the test more often
---
.../camel/component/jms/issues/JmsInOutRoutingSlipTest.java | 13 ++++++++-----
1 file changed, 8 insertions(+), 5 deletions(-)
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutRoutingSlipTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutRoutingSlipTest.java
index 73506578075..220c33e6415 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutRoutingSlipTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutRoutingSlipTest.java
@@ -24,27 +24,30 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.jms.AbstractJMSTest;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.infra.core.CamelContextExtension;
-import org.apache.camel.test.infra.core.DefaultCamelContextExtension;
+import org.apache.camel.test.infra.core.TransientCamelContextExtension;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Order;
-import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.RepeatedTest;
import org.junit.jupiter.api.extension.RegisterExtension;
public class JmsInOutRoutingSlipTest extends AbstractJMSTest {
@Order(2)
@RegisterExtension
- public static CamelContextExtension camelContextExtension = new DefaultCamelContextExtension();
+ public static CamelContextExtension camelContextExtension = new TransientCamelContextExtension();
protected CamelContext context;
protected ProducerTemplate template;
protected ConsumerTemplate consumer;
- @Test
- public void testJmsInOutRoutingSlip() throws Exception {
+ @BeforeEach
+ void setupMocks() {
getMockEndpoint("mock:JmsInOutRoutingSlipTest.foo").expectedBodiesReceived("World");
getMockEndpoint("mock:JmsInOutRoutingSlipTest.result").expectedBodiesReceived("Bye World");
getMockEndpoint("mock:end").expectedBodiesReceived("Bye World");
+ }
+ @RepeatedTest(5)
+ public void testJmsInOutRoutingSlip() throws Exception {
template.sendBodyAndHeader("activemq:queue:JmsInOutRoutingSlipTest.start", "World", "slip",
"activemq:queue:JmsInOutRoutingSlipTest.foo,activemq:queue:JmsInOutRoutingSlipTest.result");