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/26 07:42:43 UTC
(camel) branch main updated (c0e3d4796cb -> c9cb0b47ee9)
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
from c0e3d4796cb (chores) camel-test-infra-rocketmq: upgrade to the latest container image
new c2ad3be4191 CAMEL-19832: send more messages to force them to be pulled
new c9cb0b47ee9 CAMEL-19832: use a fresh JVM for every integration test
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
components/camel-rocketmq/pom.xml | 16 +++++++++++++++-
.../component/rocketmq/RocketMQRequestReplyRouteIT.java | 6 +++++-
.../apache/camel/component/rocketmq/RocketMQRouteIT.java | 8 ++++++--
3 files changed, 26 insertions(+), 4 deletions(-)
(camel) 02/02: CAMEL-19832: use a fresh JVM for every integration test
Posted by or...@apache.org.
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 c9cb0b47ee99c572618bc63f17761fef58922874
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Mar 26 04:36:22 2024 +0100
CAMEL-19832: use a fresh JVM for every integration test
---
components/camel-rocketmq/pom.xml | 16 +++++++++++++++-
1 file changed, 15 insertions(+), 1 deletion(-)
diff --git a/components/camel-rocketmq/pom.xml b/components/camel-rocketmq/pom.xml
index 28d4389b87d..34a57a7f565 100644
--- a/components/camel-rocketmq/pom.xml
+++ b/components/camel-rocketmq/pom.xml
@@ -18,7 +18,8 @@
-->
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
@@ -76,4 +77,17 @@
<scope>test</scope>
</dependency>
</dependencies>
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-failsafe-plugin</artifactId>
+ <configuration>
+ <skipITs>${skipITs}</skipITs>
+ <reuseForks>false</reuseForks>
+ </configuration>
+ </plugin>
+ </plugins>
+ </build>
</project>
(camel) 01/02: CAMEL-19832: send more messages to force them to be pulled
Posted by or...@apache.org.
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 c2ad3be41919d7df9593a30aab6db9fd1f03548c
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Fri Mar 22 11:48:35 2024 +0100
CAMEL-19832: send more messages to force them to be pulled
---
.../camel/component/rocketmq/RocketMQRequestReplyRouteIT.java | 6 +++++-
.../java/org/apache/camel/component/rocketmq/RocketMQRouteIT.java | 8 ++++++--
2 files changed, 11 insertions(+), 3 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 ccad6958a12..eb9ec64648f 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
@@ -54,6 +54,8 @@ public class RocketMQRequestReplyRouteIT extends RocketMQTestSupport {
private static final String EXPECTED_MESSAGE = "Hi.";
+ private static final int MESSAGE_COUNT = 5;
+
private MockEndpoint resultEndpoint;
private DefaultMQPushConsumer replierConsumer;
@@ -119,7 +121,9 @@ public class RocketMQRequestReplyRouteIT extends RocketMQTestSupport {
resultEndpoint.expectedBodiesReceived(EXPECTED_MESSAGE);
resultEndpoint.message(0).header(RocketMQConstants.TOPIC).isEqualTo("REPLY_TO_TOPIC");
- template.sendBody(START_ENDPOINT_URI, "hello, RocketMQ.");
+ for (int i = 0; i < MESSAGE_COUNT; i++) {
+ template.sendBody(START_ENDPOINT_URI, "hello, RocketMQ.");
+ }
resultEndpoint.assertIsSatisfied();
}
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 8af0c846da6..9cede0d4ccb 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
@@ -41,9 +41,11 @@ public class RocketMQRouteIT extends RocketMQTestSupport {
private static final String RESULT_ENDPOINT_URI = "mock:result";
+ private static final int MESSAGE_COUNT = 5;
+
private MockEndpoint resultEndpoint;
- private CountDownLatch latch = new CountDownLatch(1);
+ private CountDownLatch latch = new CountDownLatch(MESSAGE_COUNT);
@BeforeAll
static void beforeAll() throws Exception {
@@ -87,7 +89,9 @@ public class RocketMQRouteIT extends RocketMQTestSupport {
resultEndpoint.message(0).header(RocketMQConstants.TOPIC).isEqualTo("START_TOPIC");
resultEndpoint.message(0).header(RocketMQConstants.TAG).isEqualTo("startTag");
- template.sendBody(START_ENDPOINT_URI, EXPECTED_MESSAGE);
+ for (int i = 0; i < MESSAGE_COUNT; i++) {
+ template.sendBody(START_ENDPOINT_URI, EXPECTED_MESSAGE);
+ }
Assertions.assertTrue(latch.await(5, TimeUnit.SECONDS), "Should have received a message");
resultEndpoint.assertIsSatisfied();