org.springframework.cloud.fn.supplier.tcp

Class TcpSupplierConfiguration

java.lang.Object

org.springframework.cloud.fn.supplier.tcp.TcpSupplierConfiguration

@Configuration(proxyBeanMethods=false)
 @EnableConfigurationProperties(value={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 Summary

Constructors

Constructor and Description
TcpSupplierConfiguration()

Method Summary

Modifier and Type	Method and Description
org.springframework.integration.ip.tcp.TcpReceivingChannelAdapter	adapter(org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory connectionFactory)
org.springframework.integration.ip.config.TcpConnectionFactoryFactoryBean	tcpSourceConnectionFactory(TcpConnectionFactoryProperties tcpConnectionProperties, org.springframework.integration.ip.tcp.serializer.AbstractByteArraySerializer decoder)
EncoderDecoderFactoryBean	tcpSourceDecoder(TcpSupplierProperties properties)
Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<Object>>>	tcpSupplier(org.reactivestreams.Publisher<org.springframework.messaging.Message<Object>> tcpSupplierFlow, org.springframework.integration.ip.tcp.TcpReceivingChannelAdapter tcpReceivingChannelAdapter)
org.reactivestreams.Publisher<org.springframework.messaging.Message<Object>>	tcpSupplierFlow(org.springframework.integration.ip.tcp.TcpReceivingChannelAdapter adapter)

Methods inherited from class java.lang.Object

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

Constructor Detail

TcpSupplierConfiguration

public TcpSupplierConfiguration()

Method Detail

tcpSourceDecoder

@Bean
public EncoderDecoderFactoryBean tcpSourceDecoder(TcpSupplierProperties properties)

tcpSourceConnectionFactory

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

adapter

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

tcpSupplierFlow

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

tcpSupplier

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