org.springframework.cloud.stream.app.tcp.source

Class TcpSourceConfiguration

java.lang.Object

org.springframework.cloud.stream.app.tcp.source.TcpSourceConfiguration

@EnableBinding(value=org.springframework.cloud.stream.messaging.Source.class)
 @EnableConfigurationProperties(value={TcpSourceProperties.class,TcpConnectionFactoryProperties.class})
public class TcpSourceConfiguration
extends Object

A source module that receives data over TCP.

Author:

Gary Russell, Christian Tzolov

Constructor Summary

Constructors

Constructor and Description
TcpSourceConfiguration()

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(org.springframework.integration.ip.tcp.serializer.AbstractByteArraySerializer decoder)
EncoderDecoderFactoryBean	tcpSourceDecoder()

Methods inherited from class java.lang.Object

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

Constructor Detail

TcpSourceConfiguration

public TcpSourceConfiguration()

Method Detail

adapter

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

tcpSourceConnectionFactory

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

Throws:

Exception

tcpSourceDecoder

@Bean
public EncoderDecoderFactoryBean tcpSourceDecoder()