Skip to content

The FluxMessageChannel does not honor back-pressure #9215

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom
Closed
artembilan opened this issue Jun 6, 2024 · 0 comments
Closed

The FluxMessageChannel does not honor back-pressure #9215

artembilan opened this issue Jun 6, 2024 · 0 comments
Labels
(EOL) for: backport-to-6.2.x for: backport-to-6.3.x in: core status: backported type: bug
Milestone
6.4.0-M1

Comments

@artembilan
Copy link
Member

Related issue: spring-cloud/spring-cloud-stream#2957.
@artembilan artembilan added this to the 6.4.0-M1 milestone Jun 6, 2024
@artembilan artembilan mentioned this issue Jun 6, 2024
Closed
spring-builds pushed a commit that referenced this issue Jun 6, 2024
@artembilan @spring-builds
GH-9215: Honor back-pressure in FluxMessageChannel
f3ac134 
Fixes: #9215

* Instead of `share()` use `publish(1).refCount()` to prefetch only item from upstream.
* Also remove `publishOn(this.scheduler)` for upstream publishers in favor of opt-in on the consumer side.

(cherry picked from commit e9561b4)
spring-builds pushed a commit that referenced this issue Jun 6, 2024
@artembilan @spring-builds
GH-9215: Honor back-pressure in FluxMessageChannel
bf6c4f6 
Fixes: #9215

* Instead of `share()` use `publish(1).refCount()` to prefetch only item from upstream.
* Also remove `publishOn(this.scheduler)` for upstream publishers in favor of opt-in on the consumer side.

(cherry picked from commit e9561b4)
This was referenced Jun 6, 2024
Closed
Closed
EddieChoCho pushed a commit to EddieChoCho/spring-integration that referenced this issue Jun 26, 2024
@artembilan @EddieChoCho
spring-projectsGH-9215: Honor back-pressure in FluxMessageChannel
3fd5ed6 
Fixes: spring-projects#9215

* Instead of `share()` use `publish(1).refCount()` to prefetch only item from upstream.
* Also remove `publishOn(this.scheduler)` for upstream publishers in favor of opt-in on the consumer side.

**Auto-cherry-pick to `6.3.x` & `6.2.x`**
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
(EOL) for: backport-to-6.2.x for: backport-to-6.3.x in: core status: backported type: bug
Projects
None yet
Milestone
6.4.0-M1
Development

No branches or pull requests
2 participants
@artembilan @spring-builds