io.pivotal.java.function.http.supplier

Class HttpSupplierConfiguration

java.lang.Object

io.pivotal.java.function.http.supplier.HttpSupplierConfiguration

@EnableConfigurationProperties(value=HttpSourceProperties.class)
 @Configuration
public class HttpSupplierConfiguration
extends Object

Configuration for the HTTP Supplier.

Author:

Artem Bilan

Constructor Summary

Constructors

Constructor and Description
HttpSupplierConfiguration()

Method Summary

Modifier and Type	Method and Description
org.springframework.integration.mapping.HeaderMapper<org.springframework.http.HttpHeaders>	httpHeaderMapper()
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(HttpSourceProperties httpSourceProperties)

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpSupplierConfiguration

public HttpSupplierConfiguration()

Method Detail

httpSupplierFlow

@Bean
public org.reactivestreams.Publisher<org.springframework.messaging.Message<byte[]>> httpSupplierFlow(HttpSourceProperties httpSourceProperties)

httpHeaderMapper

@Bean
public org.springframework.integration.mapping.HeaderMapper<org.springframework.http.HttpHeaders> httpHeaderMapper()

httpSupplier

@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)