You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ji...@apache.org on 2024/02/05 10:22:16 UTC
(camel-quarkus) 18/20: added logging because of EipTest.throttle
This is an automated email from the ASF dual-hosted git repository.
jiriondrusek pushed a commit to branch camel-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit f636b28833a32bb5a2ef737ef2f488b2aa9315a0
Author: JiriOndrusek <on...@gmail.com>
AuthorDate: Mon Jan 29 16:07:09 2024 +0100
added logging because of EipTest.throttle
---
.../eip/src/main/java/org/apache/camel/quarkus/eip/it/EipRoutes.java | 1 +
1 file changed, 1 insertion(+)
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 a79bb177e6..f179eaf04d 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
@@ -124,6 +124,7 @@ public class EipRoutes extends RouteBuilder {
.setBody(e -> "Hello from thread " + Thread.currentThread().getName());
from("direct:throttle")
+ .log("Receiving '${body}' before throttle.")
.throttle(THROTTLE_MAXIMUM_REQUEST_COUNT).rejectExecution(true).delay(THROTTLE_TIMEOUT)
.log("Sending '${body}' to mock throttle.")
.to("mock:throttle");