You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by bv...@apache.org on 2022/12/17 11:59:00 UTC
[camel] branch main updated: enable tests by FromJmsToJdbcIdempotentConsumerToJms(Xa)Test and observe them on jenkins
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 <bv...@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