All Questions
Tagged with reactive spring-webflux
286
questions
1
vote
0
answers
66
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, ...
-1
votes
0
answers
25
views
defaultIfEmpty is not working eventhough my object is empty/null
defaultIfEmpty is not working eventhough my object is empty/null. I initilized list with both empty and null. In both the scenrios defaultIfEmpty is not invoked.
It is failing at the following ...
- 1,103
1
vote
0
answers
20
views
Webflux Requests handled by MVC
I want to have MVC Servlet Based & Reactive Rest Api's together in a single Spring Boot App of version 3.2 using openJDK 17.
I created a dummy app and tested a webflux api call with 2 scenarios:
...
- 235
0
votes
0
answers
32
views
Spring webflux sinks is not emitting events on demand but emitting all events in single response
I need support for multiple publishers and multiple subscribers for each publisher.
Below is the controller and service. Sinks is not emitting on demand but it is returning all the events in single ...
0
votes
0
answers
25
views
How to write enum validator in Spring boot to be used in reactive way
Problem Stmt: I want to validate the Enum values that are sent from Json format from POSTMAN via a REST API.
I followed this URL for the Enum validation
https://www.baeldung.com/javax-validations-...
0
votes
0
answers
44
views
Is it possible to run reactive mongo driver without Spring boot and Spring data?
So, we're using spring without spring boot for our project and got to the point where we need to integrate it with mongodb via reactor. The problem is when we start the app it connects to db but ...
- 1
1
vote
1
answer
277
views
Server Side events consumer from spring boot
Given that i have this service-A with this endpoint which returns contentType(MediaType.TEXT_EVENT_STREAM)
@Bean
public RouterFunction<ServerResponse> notificationsRoute(CustomHandler ...
- 25
1
vote
0
answers
43
views
How does Spring WebFlux get a response from external service?
I am new to reactive programming with Spring and I am trying to understand it. For example we have an http integration with an other service. I have read that in reactive Spring it is possible with ...
1
vote
1
answer
80
views
Saving to Reactive Redis and Postgres in a single transaction
I would like the saving to Postgres and Redis to be executed within a transaction, meaning if either of the saves encounters an error, the other save should be rolled back. How can this be achieved? I ...
- 11
0
votes
0
answers
57
views
Is there any reason to use pipeline with reactiveRedisTemplate?
now I'm using Spring Webflux with Redis.
Since i use Webflux, i chose ReactiveRedisTemplate to use on non-blocking system properly.
After using ReactiveRedisTemplate, i just think of how i can improve ...
0
votes
0
answers
28
views
Broken pipe issue happens immediately after returning 404
I have three services A, B and C. A uses mono zip to call both B and C with timeout 2s. In the happy path, the call to B and C all succeed, and A would aggregate the result which I don’t see broken ...
- 29
0
votes
1
answer
50
views
How to call a method with non reactive arguments with .map returning Mono
protected Flux<ProspectContact> transformAndCallUpdateAPI(String eventHubMessage) {
Mono.justOrEmpty(eventHubMessage)
.map(this::parser)
.map(this::parseToRequest) //...
0
votes
0
answers
496
views
How to get MDC context in reactive calls
I've followed the method shared in this repo to attach MDC information to logs in a reactive Spring Boot 3 application, but in my toy application when I try to use contextWrite to add an "mdc&...
- 182
1
vote
1
answer
171
views
Launching fire and forget job via kotlin coroutines in Webflux application
I am rewriting very basic webflux application into kotlin coroutines for comparison purposes, meaning instead of reactor API, I am using suspend functions with Flows.
I am using webflux with postgres ...
0
votes
1
answer
89
views
Ensure unique id by checking value in DB which returns mono
There is a requirement to generate a unique id based on a format received from request.
Before inserting to DB, need to check if it already present, then generate a new if not present in DB.
Currently,...
