[jira] [Commented] (CAMEL-20357) camel-core - throttle EIP doesn't work as expected when it's in a loopDoWhile

["Papa John (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/CAMEL-20357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810183#comment-17810183 ] 

Papa John commented on CAMEL-20357:
-----------------------------------

Somehow I don't think this is a minor issue. It makes it impossible to use `loopDoWhile` and `throttle` together, and will break many current implementation. Any thoughts?

> camel-core - throttle EIP doesn't work as expected when it's in a loopDoWhile
> -----------------------------------------------------------------------------
>
>                 Key: CAMEL-20357
>                 URL: https://issues.apache.org/jira/browse/CAMEL-20357
>             Project: Camel
>          Issue Type: Bug
>          Components: camel-core
>    Affects Versions: 4.3.0
>            Reporter: Papa John
>            Priority: Minor
>
> I just upgraded my project to Apache Camel 4.3.0, and my code stop to work as expected.
> It seems there was some changes to the `throttle EIP` – it's now throttling based on the number of concurrent exchanges.
> My route uses a {{`{*}loopDoWhile{*}`}} to loop an exchange over and over, so in a sense, the concurrent exchange should always be zero (and the inflight exchange is actually zero).
> However, my loop will stop when it reached the max number of concurrent exchanges I set for the thottler.
> For example, in the following code, the loop will stop at 10th iteration. It seems the new changes didn't put loop DSL into consideration...
> {code:java}
> import org.apache.camel.builder.RouteBuilder;public class Test extends RouteBuilder {    @Override
>     public void configure() throws Exception {        // Write your routes here, for example:
>         from("timer:java?delay=1000&repeatCount=1")
>             .loopDoWhile(constant(true)).breakOnShutdown()
>                 .throttle(10)
>                 .setBody()
>                     .simple("Hello Camel from ${routeId}")
>                 .log("${body}");
>     }
> } {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)