This is an automated email from the ASF dual-hosted git repository. bvahdat pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push: new e5899213a4c enable tests by FromJmsToJdbcIdempotentConsumerToJms(Xa)Test and observe them on jenkins e5899213a4c is described below commit e5899213a4cc2464b382d7fafd2f961a18ab7ebb Author: Babak Vahdat <bvah...@apache.org> AuthorDate: Sat Dec 17 12:57:42 2022 +0100 enable tests by FromJmsToJdbcIdempotentConsumerToJms(Xa)Test and observe them on jenkins --- .../itest/sql/FromJmsToJdbcIdempotentConsumerToJmsTest.java | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) diff --git a/tests/camel-itest/src/test/java/org/apache/camel/itest/sql/FromJmsToJdbcIdempotentConsumerToJmsTest.java b/tests/camel-itest/src/test/java/org/apache/camel/itest/sql/FromJmsToJdbcIdempotentConsumerToJmsTest.java index c7aa8cefa65..37ee580a563 100644 --- a/tests/camel-itest/src/test/java/org/apache/camel/itest/sql/FromJmsToJdbcIdempotentConsumerToJmsTest.java +++ b/tests/camel-itest/src/test/java/org/apache/camel/itest/sql/FromJmsToJdbcIdempotentConsumerToJmsTest.java @@ -30,7 +30,6 @@ import org.apache.camel.itest.ITestSupport; import org.apache.camel.spi.IdempotentRepository; import org.apache.camel.test.spring.junit5.CamelSpringTestSupport; import org.junit.jupiter.api.BeforeEach; -import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.springframework.context.support.AbstractApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; @@ -64,8 +63,8 @@ public class FromJmsToJdbcIdempotentConsumerToJmsTest extends CamelSpringTestSup jdbcTemplate.afterPropertiesSet(); // cater for slow servers - getMockEndpoint("mock:a").setResultWaitTime(30000); - getMockEndpoint("mock:b").setResultWaitTime(30000); + getMockEndpoint("mock:a").setResultWaitTime(40000); + getMockEndpoint("mock:b").setResultWaitTime(40000); } protected String getDatasourceName() { @@ -96,7 +95,6 @@ public class FromJmsToJdbcIdempotentConsumerToJmsTest extends CamelSpringTestSup assertEquals("DONE-A", out); } - @Disabled("see the TODO below") @Test void testJmsToJdbcJmsRollbackAtA() throws Exception { checkInitialState(); @@ -104,7 +102,6 @@ public class FromJmsToJdbcIdempotentConsumerToJmsTest extends CamelSpringTestSup // use a notify to know that after 1+6 (1 original + 6 redelivery) attempts from AcitveMQ NotifyBuilder notify = new NotifyBuilder(context).whenDone(7).create(); - // TODO: occasionally we get only 6 instead of 7 expected exchanges which's most probably an issue in ActiveMQ itself getMockEndpoint("mock:a").expectedMessageCount(7); // force exception to occur at mock a getMockEndpoint("mock:a").whenAnyExchangeReceived(new Processor() { @@ -130,7 +127,6 @@ public class FromJmsToJdbcIdempotentConsumerToJmsTest extends CamelSpringTestSup assertEquals("A", consumer.receiveBody("activemq2:queue:ActiveMQ.DLQ", 3000)); } - @Disabled("see the TODO below") @Test void testJmsToJdbcJmsRollbackAtB() throws Exception { checkInitialState(); @@ -138,7 +134,6 @@ public class FromJmsToJdbcIdempotentConsumerToJmsTest extends CamelSpringTestSup // use a notify to know that after 1+6 (1 original + 6 redelivery) attempts from AcitveMQ NotifyBuilder notify = new NotifyBuilder(context).whenDone(7).create(); - // TODO: occasionally we get only 6 instead of 7 expected exchanges which's most probably an issue in ActiveMQ itself getMockEndpoint("mock:a").expectedMessageCount(7); getMockEndpoint("mock:b").expectedMessageCount(7); // force exception to occur at mock b