spring-webflux Questions

4

Solved

I'm facing some problem while sending request body in spring boot web client. Trying to send body like below: val body = "{\n" + "\"email\":\"[email protected]\",\n" + "\"id\":1\n" + "}" v...
Coreencorel asked 9/11, 2018 at 12:3

4

Solved

How can we handle exceptions globally when using reactive programming in Spring boot rest controller? I would assume that @ControllerAdvice will not work because I have tried this and it was unsucc...
Jovitajovitah asked 26/6, 2019 at 16:58

10

I'm using a spring-webflux WebClient (build 20170502.221452-172) to access a Web application producing a stream of Entry objects (application/stream+json) like this: final WebClient producerClient...
Merrileemerrili asked 3/5, 2017 at 20:20

2

Solved

I don't understand the use and the difference between then, thenEmpty, thenMany and flatMapMany on Flux or Mono in spring webflux.
Diegodiehard asked 14/1, 2018 at 22:24

4

I'm searching a way to use scheduled tasks in a reactive API. I know that it uses the thread pool so it's not very compatible with the webflux components. Do you have an equivalent to do the job?
Pantelegraph asked 8/1, 2019 at 13:42

20

Solved

I'm trying to log a request using Spring 5 WebClient. Do you have any idea how could I achieve that? (I'm using Spring 5 and Spring boot 2) The code looks like this at the moment: try { return...
Maier asked 11/9, 2017 at 11:46

6

Solved

I'm not able to open more than 10 connections with spring-webflux and r2dbc (with r2dbc-pool driver 0.8.0.M8). My config looks like: @Configuration public class PostgresConfig extends AbstractR2db...
Lactation asked 17/9, 2019 at 9:26

3

I'm building a Spring WebClient which internally calls to REST API's which are hosted in different server. To do that I need to send public key (.cert) and private key (.key) to every request for t...
Curiel asked 1/10, 2019 at 22:38

1

I have a code where I can execute a piece of logic in loop with some delays in between using Flux. Something like this, Flux.defer(() -> service.doSomething()) .repeatWhen(v -> Flux.interval...
Unjust asked 3/11, 2023 at 18:38

3

Solved

How many concurrent requests can I send if the remote service if blocking? Means: what is the maxConnection pool limit that spring uses internally when using WebClient? @Autowired private WebClien...
Molecule asked 27/8, 2019 at 11:29

1

Solved

Libraries: r2dbc-postgresql-0.8.6.RELEASE r2dbc-pool-0.8.5.RELEASE r2dbc-spi-0.8.3.RELEASE postgresql-42.2.18 List item Problem: I tried to bulk insert using R2DBC (PostgreSQL) with code as below...

2

Solved

The code below executes all web requests (webClient) in parallel, not respecting the limit I put in parallel(5). Flux.fromIterable(dataListWithHundredsElements) .parallel(5).runOn(Schedulers.bou...
Endothelium asked 8/5, 2020 at 10:9

5

Solved

I am using webflux Mono (in Spring boot 5) to consume an external API. I am able to get data well when the API response status code is 200, but when the API returns an error I am not able to retrie...
Sinusoidal asked 26/3, 2018 at 6:52

6

I'd like to stay complete reactive within my new spring application. Therefor I use web-flux/ reactor and ReactiveRepository with MongoDB. Do you know how to integrate java-mail reactively into th...
Alluvial asked 28/6, 2018 at 22:16

3

Solved

I have a Spring Webflux reactive service which receives a DTO and inserts it into multiple table. Sometimes we may need to skip inserting into some tables based on the incoming DTO. These are the r...
Flintlock asked 26/2, 2021 at 22:19

8

Solved

Application was working with Springfox Swagger 3.0 few days back. Suddenly it is stopped working. The Jar file which was created before a week is still working but now when we try to build a new Ja...
Morganmorgana asked 7/7, 2020 at 10:28

1

I am working on a project that uses the Spring WebFlux stack. We have a Controller where you can subscribe for updates on a specific object. This Controller returns an EmitterProcessor where client...
Alcoholometer asked 30/1, 2019 at 13:19

3

Solved

Could someone help me to understand the difference between: Mono.defer() Mono.create() Mono.just() How to use it properly?
Notation asked 13/5, 2019 at 15:25

4

Solved

I have refactored my code to use spring webflux but now @Valid stopped working. It is not validating the request body. @PostMapping(value = "/getContactInfo",produces = "application/json",consumes...
Reredos asked 21/12, 2018 at 16:21

4

I have a WebClient that sends a JSON object with login credentials to a remote server. The remote server then returns the cookie. After which I need to POST data to that remote server along with th...
Cedillo asked 7/4, 2019 at 9:47

7

Solved

I've been doing some research using spring-webflux and I like to understand what should be the right way to handle errors using Router Functions. I've created an small project to test a couple of ...
Deyoung asked 23/4, 2017 at 19:24

5

Solved

I am trying to create my own ErrorWebExceptionHandler in Spring Boot 2 by extending the default one but my application fails to start with the following message: Caused by: java.lang.IllegalArgume...
Brickwork asked 25/9, 2018 at 12:8

3

Solved

I want to implement simple Spring Security WebFlux application. I want to use JSON message like { 'username': 'admin', 'password': 'adminPassword' } in body (POST request to /signin) to sig...
Ahola asked 25/4, 2018 at 6:46

3

Solved

I want to create a new project with Spring Cloud Gateway but I don't want all the reactive functionality. for me, it will be fine if the other microservice will be blocking I/O and not Reactive. h...
Johnsonian asked 21/1, 2021 at 8:52

2

Solved

new to Spring WebFlux, trying to return array of strings in one endpoint and for some reason it returns one concatenated string istead of JSON array. Wrapping it with some class solves the proble...
Schottische asked 24/1, 2018 at 11:38

© 2022 - 2024 — McMap. All rights reserved.