How to set a timeout in Spring 5 WebFlux WebClient

by

To set the read and connect timeout I use the method below, because the SO_TIMEOUT option is not available for channels using NIO (and giving the warning Unknown channel option 'SO_TIMEOUT' for channel '[id: 0xa716fcb2]')

ReactorClientHttpConnector connector = new ReactorClientHttpConnector(
          options -> options.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 2000)
                            .compression(true)
                            .afterNettyContextInit(ctx -> {
                                ctx.addHandlerLast(new ReadTimeoutHandler(5000, TimeUnit.MILLISECONDS));
                            }));
return WebClient.builder()
                .clientConnector(connector)
                .build();

More Related Contents:

  1. Fire and forget with reactor
  2. Spring 5 WebClient using ssl
  3. How does backpressure work in Project Reactor?
  4. Spring Boot – Loading Initial Data
  5. How Spring Security Filter Chain works
  6. Spring @Transactional read-only propagation
  7. Disable all Database related auto configuration in Spring Boot
  8. How to write a custom filter in spring security?
  9. How Do I Create Many to Many Hibernate Mapping for Additional Property from the Join Table?
  10. Send datas from html to controller in Thymeleaf?
  11. Spring HandlerInterceptor vs Servlet Filters
  12. SpringServletContainerInitializer cannot be cast to javax.servlet.ServletContainerInitializer
  13. Access properties file programmatically with Spring?
  14. Inject and Resource and Autowired annotations
  15. Scope of a Spring-Controller and its instance-variables
  16. Could not build ClassFile – ArchiveException
  17. How can I specify my .keystore file with Spring Boot and Tomcat?
  18. why does transaction roll back on RuntimeException but not SQLException
  19. Spring boot: configure it to find the webapp folder
  20. Looking for a Simple Spring security example [closed]
  21. Dependency Injection in JSR-303 Constraint Validator with Spring fails
  22. Spring MVC bean mapping to HTTP GET request parameters similar to @BeanParam
  23. Where to handle Exceptions in Spring Applications
  24. Self-invocation behaviour in @Configuration vs. @Component classes
  25. Programmatic access to properties created by property-placeholder
  26. Where should I place my Vaadin 10+ static files?
  27. Is it possible to invalidate a spring security session?
  28. Unable to connect to Command Metric Stream. in Hystrix Dashboard issue
  29. How to add a custom health check in spring boot health?
  30. @SpringBootTest vs @ContextConfiguration vs @Import in Spring Boot Unit Test

Leave a Comment