Package org.springframework.cloud.fn.supplier.http

Class HttpSupplierConfiguration

java.lang.Object

org.springframework.cloud.fn.supplier.http.HttpSupplierConfiguration

@EnableConfigurationProperties(HttpSupplierProperties.class)
@Configuration
public class HttpSupplierConfiguration
extends Object

Configuration for the HTTP Supplier.

Author:

Artem Bilan

Constructor Summary

Constructors

Constructor	Description
HttpSupplierConfiguration()

Method Summary

Modifier and Type	Method	Description
org.springframework.integration.mapping.HeaderMapper<HttpHeaders>	httpHeaderMapper(HttpSupplierProperties httpSupplierProperties)
Supplier<reactor.core.publisher.Flux<Message<byte[]>>>	httpSupplier(org.reactivestreams.Publisher<Message<byte[]>> httpRequestPublisher, org.springframework.integration.webflux.inbound.WebFluxInboundEndpoint webFluxInboundEndpoint)
org.reactivestreams.Publisher<Message<byte[]>>	httpSupplierFlow(HttpSupplierProperties httpSupplierProperties, org.springframework.integration.mapping.HeaderMapper<HttpHeaders> httpHeaderMapper, ServerCodecConfigurer serverCodecConfigurer)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

HttpSupplierConfiguration

public HttpSupplierConfiguration()

Method Details

httpHeaderMapper

@Bean
@ConditionalOnMissingBean
public org.springframework.integration.mapping.HeaderMapper<HttpHeaders> httpHeaderMapper(HttpSupplierProperties httpSupplierProperties)

httpSupplierFlow

@Bean
public org.reactivestreams.Publisher<Message<byte[]>> httpSupplierFlow(HttpSupplierProperties httpSupplierProperties,
 org.springframework.integration.mapping.HeaderMapper<HttpHeaders> httpHeaderMapper,
 ServerCodecConfigurer serverCodecConfigurer)

httpSupplier

@Bean
public Supplier<reactor.core.publisher.Flux<Message<byte[]>>> httpSupplier(org.reactivestreams.Publisher<Message<byte[]>> httpRequestPublisher,
 org.springframework.integration.webflux.inbound.WebFluxInboundEndpoint webFluxInboundEndpoint)