You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by pp...@apache.org on 2021/07/29 06:08:43 UTC
[camel-quarkus] 02/10: Test roundRobin() EIP #2628
This is an automated email from the ASF dual-hosted git repository.
ppalaga pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 9fda0283b19298b782894f0146f6f5504a000b30
Author: Peter Palaga <pp...@redhat.com>
AuthorDate: Fri Jul 23 19:10:13 2021 +0200
Test roundRobin() EIP #2628
---
.../org/apache/camel/quarkus/eip/it/EipRoutes.java | 4 ++++
.../org/apache/camel/quarkus/eip/it/EipTest.java | 24 ++++++++++++++++++++++
2 files changed, 28 insertions(+)
diff --git a/integration-test-groups/foundation/eip/src/main/java/org/apache/camel/quarkus/eip/it/EipRoutes.java b/integration-test-groups/foundation/eip/src/main/java/org/apache/camel/quarkus/eip/it/EipRoutes.java
index 027a174..6258215 100644
--- a/integration-test-groups/foundation/eip/src/main/java/org/apache/camel/quarkus/eip/it/EipRoutes.java
+++ b/integration-test-groups/foundation/eip/src/main/java/org/apache/camel/quarkus/eip/it/EipRoutes.java
@@ -44,6 +44,10 @@ public class EipRoutes extends RouteBuilder {
.loadBalance().custom("roundRobin")
.to("mock:customLoadBalancer1", "mock:customLoadBalancer2");
+ from("direct:roundRobinLoadBalancer")
+ .loadBalance().roundRobin()
+ .to("mock:roundRobinLoadBalancer1", "mock:roundRobinLoadBalancer2");
+
from("direct:enrich")
.enrich("direct:prepend-hello");
diff --git a/integration-test-groups/foundation/eip/src/test/java/org/apache/camel/quarkus/eip/it/EipTest.java b/integration-test-groups/foundation/eip/src/test/java/org/apache/camel/quarkus/eip/it/EipTest.java
index 9b5ad62..423cb32 100644
--- a/integration-test-groups/foundation/eip/src/test/java/org/apache/camel/quarkus/eip/it/EipTest.java
+++ b/integration-test-groups/foundation/eip/src/test/java/org/apache/camel/quarkus/eip/it/EipTest.java
@@ -70,6 +70,30 @@ class EipTest {
}
@Test
+ public void roundRobinLoadBalancer() {
+ final List<String> messages = Arrays.asList("a", "b", "c", "d");
+ for (String msg : messages) {
+ RestAssured.given()
+ .contentType(ContentType.TEXT)
+ .body(msg)
+ .post("/eip/route/roundRobinLoadBalancer")
+ .then()
+ .statusCode(200);
+ }
+
+ RestAssured.get("/eip/mock/roundRobinLoadBalancer1/2/10000/body")
+ .then()
+ .statusCode(200)
+ .body(Matchers.is("a,c"));
+
+ RestAssured.get("/eip/mock/roundRobinLoadBalancer2/2/10000/body")
+ .then()
+ .statusCode(200)
+ .body(Matchers.is("b,d"));
+
+ }
+
+ @Test
public void enrich() {
RestAssured.given()
.contentType(ContentType.TEXT)