Package org.springframework.cloud.fn.supplier.tcp

Class TcpSupplierConfiguration

java.lang.Object
org.springframework.cloud.fn.supplier.tcp.TcpSupplierConfiguration
@Configuration(proxyBeanMethods=false) @EnableConfigurationProperties({TcpSupplierProperties.class,TcpConnectionFactoryProperties.class}) public class TcpSupplierConfiguration extends Object
A source module that receives data over TCP.
Author:
Gary Russell, Christian Tzolov, Soby Chacko, Artem Bilan

  • Constructor Details

    • TcpSupplierConfiguration

      public TcpSupplierConfiguration()

  • Method Details

    • tcpSourceDecoder

      @Bean public EncoderDecoderFactoryBean tcpSourceDecoder(TcpSupplierProperties properties)

    • tcpSourceConnectionFactory

      @Bean public org.springframework.integration.ip.config.TcpConnectionFactoryFactoryBean tcpSourceConnectionFactory(TcpConnectionFactoryProperties tcpConnectionProperties, @Qualifier("tcpSourceDecoder") org.springframework.integration.ip.tcp.serializer.AbstractByteArraySerializer decoder)

    • adapter

      @Bean public org.springframework.integration.ip.tcp.TcpReceivingChannelAdapter adapter(@Qualifier("tcpSourceConnectionFactory") org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory connectionFactory)

    • tcpSupplierFlow

      @Bean public org.reactivestreams.Publisher<Message<Object>> tcpSupplierFlow(org.springframework.integration.ip.tcp.TcpReceivingChannelAdapter adapter)

    • tcpSupplier

      @Bean public Supplier<reactor.core.publisher.Flux<Message<Object>>> tcpSupplier(org.reactivestreams.Publisher<Message<Object>> tcpSupplierFlow, org.springframework.integration.ip.tcp.TcpReceivingChannelAdapter tcpReceivingChannelAdapter)