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

Class TcpClientSourceConfiguration

java.lang.Object

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

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

A source application that acts as a TCP client.

Author:

Ilayaperumal Gopinathan, Gary Russell, Christian Tzolov

Constructor Summary

Constructors

Constructor and Description
TcpClientSourceConfiguration()

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	tcpClientConnectionFactory(org.springframework.integration.ip.tcp.connection.TcpMessageMapper mapper, org.springframework.integration.ip.tcp.serializer.AbstractByteArraySerializer decoder)
EncoderDecoderFactoryBean	tcpClientDecoder()
org.springframework.integration.ip.tcp.connection.TcpMessageMapper	tcpClientMapper()

Methods inherited from class java.lang.Object

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

Constructor Detail

TcpClientSourceConfiguration

public TcpClientSourceConfiguration()

Method Detail

adapter

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

tcpClientConnectionFactory

@Bean
public org.springframework.integration.ip.config.TcpConnectionFactoryFactoryBean tcpClientConnectionFactory(@Qualifier(value="tcpClientMapper")
                                                                                                                  org.springframework.integration.ip.tcp.connection.TcpMessageMapper mapper,
                                                                                                                  @Qualifier(value="tcpClientDecoder")
                                                                                                                  org.springframework.integration.ip.tcp.serializer.AbstractByteArraySerializer decoder)
                                                                                                           throws Exception

Throws:

Exception

tcpClientMapper

@Bean
public org.springframework.integration.ip.tcp.connection.TcpMessageMapper tcpClientMapper()

tcpClientDecoder

@Bean
public EncoderDecoderFactoryBean tcpClientDecoder()