org.springframework.cloud.stream.app.tcp.sink

Class TcpSinkConfiguration

java.lang.Object

org.springframework.cloud.stream.app.tcp.sink.TcpSinkConfiguration

@EnableBinding(value=org.springframework.cloud.stream.messaging.Sink.class)
 @EnableConfigurationProperties(value={TcpSinkProperties.class,TcpConnectionFactoryProperties.class})
public class TcpSinkConfiguration
extends Object

A sink application that sends data over TCP.

Author:

Gary Russell, Christian Tzolov

Constructor Summary

Constructors

Constructor and Description
TcpSinkConfiguration()

Method Summary

Modifier and Type	Method and Description
org.springframework.integration.ip.tcp.TcpSendingMessageHandler	handler(org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory connectionFactory)
org.springframework.integration.ip.config.TcpConnectionFactoryFactoryBean	tcpSinkConnectionFactory(org.springframework.integration.ip.tcp.serializer.AbstractByteArraySerializer encoder, org.springframework.integration.ip.tcp.connection.TcpMessageMapper mapper)
EncoderDecoderFactoryBean	tcpSinkEncoder()
org.springframework.integration.ip.tcp.connection.TcpMessageMapper	tcpSinkMapper()

Methods inherited from class java.lang.Object

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

Constructor Detail

TcpSinkConfiguration

public TcpSinkConfiguration()

Method Detail

handler

@Bean
 @ServiceActivator(inputChannel="input")
public org.springframework.integration.ip.tcp.TcpSendingMessageHandler handler(@Qualifier(value="tcpSinkConnectionFactory")
                                                                                                                              org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory connectionFactory)

tcpSinkConnectionFactory

@Bean
public org.springframework.integration.ip.config.TcpConnectionFactoryFactoryBean tcpSinkConnectionFactory(@Qualifier(value="tcpSinkEncoder")
                                                                                                                org.springframework.integration.ip.tcp.serializer.AbstractByteArraySerializer encoder,
                                                                                                                @Qualifier(value="tcpSinkMapper")
                                                                                                                org.springframework.integration.ip.tcp.connection.TcpMessageMapper mapper)
                                                                                                         throws Exception

Throws:

Exception

tcpSinkEncoder

@Bean
public EncoderDecoderFactoryBean tcpSinkEncoder()

tcpSinkMapper

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