You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2023/05/23 05:07:03 UTC
[camel] branch main updated: CAMEL-19377: camel-platform-http-vertx - Add test for suspended consumer
This is an automated email from the ASF dual-hosted git repository.
davsclaus 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 a907ceb4bb0 CAMEL-19377: camel-platform-http-vertx - Add test for suspended consumer
a907ceb4bb0 is described below
commit a907ceb4bb0679dc9fe15827bd4596d7eb38b746
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Tue May 23 07:06:49 2023 +0200
CAMEL-19377: camel-platform-http-vertx - Add test for suspended consumer
---
.../http/vertx/VertxPlatformHttpEngineTest.java | 36 ++++++++++++++++++++++
1 file changed, 36 insertions(+)
diff --git a/components/camel-platform-http-vertx/src/test/java/org/apache/camel/component/platform/http/vertx/VertxPlatformHttpEngineTest.java b/components/camel-platform-http-vertx/src/test/java/org/apache/camel/component/platform/http/vertx/VertxPlatformHttpEngineTest.java
index 8b4291e3a17..23c45b5f94f 100644
--- a/components/camel-platform-http-vertx/src/test/java/org/apache/camel/component/platform/http/vertx/VertxPlatformHttpEngineTest.java
+++ b/components/camel-platform-http-vertx/src/test/java/org/apache/camel/component/platform/http/vertx/VertxPlatformHttpEngineTest.java
@@ -714,6 +714,42 @@ public class VertxPlatformHttpEngineTest {
}
}
+ @Test
+ public void testConsumerSuspended() throws Exception {
+ final CamelContext context = createCamelContext();
+
+ try {
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() {
+ from("platform-http:/get")
+ .routeId("get")
+ .setBody().constant("get");
+ }
+ });
+
+ context.start();
+
+ given()
+ .when()
+ .get("/get")
+ .then()
+ .statusCode(200)
+ .body(equalTo("get"));
+
+ context.getRouteController().suspendRoute("get");
+
+ given()
+ .when()
+ .get("/get")
+ .then()
+ .statusCode(404);
+
+ } finally {
+ context.stop();
+ }
+ }
+
static CamelContext createCamelContext() throws Exception {
return createCamelContext(null);
}