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/01/29 15:23:31 UTC

(camel-quarkus) branch camel-main updated: 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


The following commit(s) were added to refs/heads/camel-main by this push:
     new ea436ce829 added logging because of EipTest.throttle
ea436ce829 is described below

commit ea436ce8298b65e5a6d974a7b7da130cb737f477
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");