[
https://issues.apache.org/jira/browse/CAMEL-11125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nicola Ferraro reassigned CAMEL-11125:
--------------------------------------
Assignee: Nicola Ferraro
> camel-reactive-streams - Consumer should allow to not refill so frequently
> --------------------------------------------------------------------------
>
> Key: CAMEL-11125
> URL: https://issues.apache.org/jira/browse/CAMEL-11125
> Project: Camel
> Issue Type: Improvement
> Components: camel-reactive-streams
> Affects Versions: 2.19.0
> Reporter: Claus Ibsen
> Assignee: Nicola Ferraro
> Priority: Minor
>
> Every time a consumer has completed onNext it calculates a refill, and
> because it has completed 1 message, it will always ask for at least 1
> message.
> This happens even if there is 127 messages already in the buffer.
> We should probably have some way of having a low/high watermark so if the
> buffer has many messages already we dont need to refill so frequently.
> This happens in the code:
> org.apache.camel.component.reactive.streams.engine.CamelSubscriber#onNext
> By having those watermark threshold we allow to not be so chatty and request
> data all the time, but instead request data in more bulks. Otherwise chances
> are that we just keep requesting = 1 all the time.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
