Questions tagged [spring-webflux]
Spring Framework 5 includes a new spring-webflux module. The module contains support for reactive HTTP and WebSocket clients as well as for reactive server web applications including REST, HTML browser, and WebSocket style interactions. WebFlux can run on Servlet containers with support for the Servlet 3.1 non-blocking I/O API as well as on other async runtimes such as Netty and Undertow.
spring-webflux
6,382
questions
0
votes
1
answer
10
views
How to poll incoming kafka message into Flux
Currently working on a project using Spring Boot 3.2.7 with web Spring Cloud stream binders. I have a data layer which based on provider implementation is streaming some data into my service. ...
- 325
-1
votes
1
answer
21
views
Reactor doOnError - How to include multiple Exception Types in method parameters
I would like to handle multiple exceptions in the same way in the Controller of a Reactive Spring Boot API.
The idea is to send a HttpStatus.BAD_REQUEST as an error response for more than one type of ...
0
votes
0
answers
12
views
Question about request handling differences between Spring WebFlux versions 6.1.1 ~ 6.1.3 and 6.1.4
I couldn't find specific details in the issue or release notes, so I'm asking out of curiosity: Are there any differences in request handling between Spring WebFlux versions 6.1.1 ~ 6.1.3 and 6.1.4?
...
- 51
1
vote
0
answers
40
views
Spring Functional Endpoints returning 404
I'm creating an application using both regular endpoints and functional endpoints. If I hit any created with the regular endpoints, I get the desired results. But introducing the functional endpoints, ...
2
votes
0
answers
37
views
Spring WebClient retry fails because of ReadOnlyHttpHeaders
java : 21
spring-boot : 3.2.4
spring : 6.1.5
What am I looking for?
I want to retry all my requests when the http response is not 2xx successful.
Problem: Retries tries to write ...
- 21
2
votes
1
answer
52
views
Understanding execution order with .then(Mono{})
I'm trying to understand the behaviour of .then(Mono(x)) in spring webflux.
I have the following code:
fun storeIfValid(x): Mono<Long> =
doSomeChecksThatMightFail().then(repo.save(x))
...
- 45
-2
votes
0
answers
18
views
Using WebClient in an AuthenticationFilter (Spring-boot, spring-security 6.3)
I am new to Reactive programming and I have hard time understanding why it appears chaining of Mono does not work in this context. I tried various methods but with no luck. The latest approach is ...
0
votes
0
answers
36
views
Netty blocking spring integration workers
Currently I’m working on a spring integration service that uses webClient with Netty for http calls
The problem that I'm facing occurs when spring integration goes to a channel and while it is ...
- 15
0
votes
0
answers
10
views
Convert between http and rsocket
Two microservice clusters communicate using HTTP protocol. Some businesses interact between the clusters. It is expected to develop a communication service to connect the two microservice clusters so ...
- 1
-3
votes
0
answers
20
views
Application with Spring MVC using Reactive database connector, what benefit we can get? [closed]
I am having a legacy applications developed in SpringMVC/Spring boot. In the application I can see the I/O calls like to connect with DB and external service call causes thread sortage because of ...
- 51
1
vote
1
answer
16
views
Resilience4j and reactor RetryWhen not working together to distribuite 100 request at 10 requests per second
I'm calling a remote service and don't want to exceed 10 RPS, so I configured Resilience4j Rate Limiter and added retryWhen to handle RequestNotPermitted errors and retry when it is allowed.
The ...
- 24.1k
1
vote
0
answers
37
views
WebClientRequestException: Pending acquire queue has reached its maximum size of XX
for ilustration purposes I have this code:
// remote Echo server
@GetMapping("echo")
public Mono<String> echo(){
return Mono.just("echo");
}
// client 1 ...
- 1,907
0
votes
0
answers
52
views
Spring WebFlux loading large amount of data without encountering OOM
I am new to Spring WebFlux, lately i have encountered OOM in a Spring WebFlux project.
Inside this project, there is only one scheduled job runs one time per day.
The job contains the following ...
- 1
0
votes
0
answers
41
views
For an authenticated user hosted controllers are returning error response if any supporting service is throwing 401 error [closed]
We are using Spring Security OAuth2 with WebFlux, if any of our supporting API return 401 because of their implementation, current valid login is removed and subsequent calls are failing with 401 ...
- 54
0
votes
1
answer
34
views
Swagger POST request ~ Failed to fetch against Spring Boot Webflux Proxy
I am currently migrating from a Delphi Proxy to a Java Spring Webflux proxy. My requests against the migrated proxy work fine when done via Postman, but in Swagger, the POST requests fail against the ...
- 2,145