@EnableConfigurationProperties(value=HttpSupplierProperties.class) @Configuration public class HttpSupplierConfiguration extends Object
Constructor and Description |
---|
HttpSupplierConfiguration() |
Modifier and Type | Method and Description |
---|---|
org.springframework.integration.mapping.HeaderMapper<org.springframework.http.HttpHeaders> |
httpHeaderMapper(HttpSupplierProperties httpSupplierProperties) |
Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<byte[]>>> |
httpSupplier(org.reactivestreams.Publisher<org.springframework.messaging.Message<byte[]>> httpRequestPublisher,
org.springframework.integration.webflux.inbound.WebFluxInboundEndpoint webFluxInboundEndpoint) |
org.reactivestreams.Publisher<org.springframework.messaging.Message<byte[]>> |
httpSupplierFlow(HttpSupplierProperties httpSupplierProperties,
org.springframework.integration.mapping.HeaderMapper<org.springframework.http.HttpHeaders> httpHeaderMapper,
org.springframework.http.codec.ServerCodecConfigurer serverCodecConfigurer) |
@Bean @ConditionalOnMissingBean public org.springframework.integration.mapping.HeaderMapper<org.springframework.http.HttpHeaders> httpHeaderMapper(HttpSupplierProperties httpSupplierProperties)
@Bean public org.reactivestreams.Publisher<org.springframework.messaging.Message<byte[]>> httpSupplierFlow(HttpSupplierProperties httpSupplierProperties, org.springframework.integration.mapping.HeaderMapper<org.springframework.http.HttpHeaders> httpHeaderMapper, org.springframework.http.codec.ServerCodecConfigurer serverCodecConfigurer)
@Bean public Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<byte[]>>> httpSupplier(org.reactivestreams.Publisher<org.springframework.messaging.Message<byte[]>> httpRequestPublisher, org.springframework.integration.webflux.inbound.WebFluxInboundEndpoint webFluxInboundEndpoint)
Copyright © 2022. All rights reserved.