[camel] branch main updated: polish test

[bvahdat]

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 ebdd2044911 polish test
ebdd2044911 is described below

commit ebdd2044911feeb32814e9ded3e2b023ee5f522f
Author: Babak Vahdat <bvah...@apache.org>
AuthorDate: Mon Dec 26 11:53:49 2022 +0100

    polish test
---
 .../sql/FromJmsToJdbcIdempotentConsumerToJmsTest.java    | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 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 7915cb5359b..d753f31be89 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
@@ -93,7 +93,7 @@ public class FromJmsToJdbcIdempotentConsumerToJmsTest extends 
CamelSpringTestSup
         assertTrue(notify.matchesWaitTime(), "Should complete 1 message");
 
         // check that there is a message in the database and JMS queue
-        assertEquals(1, jdbcTemplate.queryForObject("select count(*) from 
CAMEL_MESSAGEPROCESSED", Integer.class));
+        assertEquals(1, jdbcTemplate.queryForObject("select count(*) from 
CAMEL_MESSAGEPROCESSED", int.class));
         Object out = consumer.receiveBody("activemq2:queue:outbox", 3000);
         assertEquals("DONE-A", out);
     }
@@ -117,7 +117,7 @@ public class FromJmsToJdbcIdempotentConsumerToJmsTest 
extends CamelSpringTestSup
         assertTrue(notify.matchesWaitTime(), "Should complete 7 messages");
 
         // check that there is no message in the database and JMS queue
-        assertEquals(0, jdbcTemplate.queryForObject("select count(*) from 
CAMEL_MESSAGEPROCESSED", Integer.class));
+        assertEquals(0, jdbcTemplate.queryForObject("select count(*) from 
CAMEL_MESSAGEPROCESSED", int.class));
         assertNull(consumer.receiveBody("activemq2:queue:outbox", 3000));
 
         // the message should have been moved to the AMQ DLQ queue
@@ -143,7 +143,7 @@ public class FromJmsToJdbcIdempotentConsumerToJmsTest 
extends CamelSpringTestSup
         assertTrue(notify.matchesWaitTime(), "Should complete 7 messages");
 
         // check that there is no message in the database and JMS queue
-        assertEquals(0, jdbcTemplate.queryForObject("select count(*) from 
CAMEL_MESSAGEPROCESSED", Integer.class));
+        assertEquals(0, jdbcTemplate.queryForObject("select count(*) from 
CAMEL_MESSAGEPROCESSED", int.class));
         assertNull(consumer.receiveBody("activemq2:queue:outbox", 3000));
 
         // the message should have been moved to the AMQ DLQ queue
@@ -168,7 +168,7 @@ public class FromJmsToJdbcIdempotentConsumerToJmsTest 
extends CamelSpringTestSup
         assertTrue(notify.matchesWaitTime(), "Should complete 3 messages");
 
         // check that there is two messages in the database and JMS queue
-        assertEquals(2, jdbcTemplate.queryForObject("select count(*) from 
CAMEL_MESSAGEPROCESSED", Integer.class));
+        assertEquals(2, jdbcTemplate.queryForObject("select count(*) from 
CAMEL_MESSAGEPROCESSED", int.class));
         assertEquals("DONE-D", consumer.receiveBody("activemq2:queue:outbox", 
3000));
         assertEquals("DONE-E", consumer.receiveBody("activemq2:queue:outbox", 
3000));
     }
@@ -204,7 +204,7 @@ public class FromJmsToJdbcIdempotentConsumerToJmsTest 
extends CamelSpringTestSup
         assertTrue(notify.matchesWaitTime(), "Should complete 4 messages");
 
         // check that there is three messages in the database and JMS queue
-        assertEquals(3, jdbcTemplate.queryForObject("select count(*) from 
CAMEL_MESSAGEPROCESSED", Integer.class));
+        assertEquals(3, jdbcTemplate.queryForObject("select count(*) from 
CAMEL_MESSAGEPROCESSED", int.class));
         assertEquals("DONE-D", consumer.receiveBody("activemq2:queue:outbox", 
3000));
         assertEquals("DONE-E", consumer.receiveBody("activemq2:queue:outbox", 
3000));
         assertEquals("DONE-F", consumer.receiveBody("activemq2:queue:outbox", 
3000));
@@ -212,7 +212,7 @@ public class FromJmsToJdbcIdempotentConsumerToJmsTest 
extends CamelSpringTestSup
 
     protected void checkInitialState() {
         // check there are no messages in the database and JMS queue
-        assertEquals(0, jdbcTemplate.queryForObject("select count(*) from 
CAMEL_MESSAGEPROCESSED", Integer.class));
+        assertEquals(0, jdbcTemplate.queryForObject("select count(*) from 
CAMEL_MESSAGEPROCESSED", int.class));
         assertNull(consumer.receiveBody("activemq2:queue:outbox", 2000));
     }
 
@@ -226,9 +226,9 @@ public class FromJmsToJdbcIdempotentConsumerToJmsTest 
extends CamelSpringTestSup
 
                 from("activemq2:queue:inbox")
                         .transacted("required")
-                        .to("mock:a")
+                        .to(mockA)
                         .idempotentConsumer(header("uid"), repository)
-                        .to("mock:b")
+                        .to(mockB)
                         .transform(simple("DONE-${body}"))
                         .to("activemq2:queue:outbox");
             }