Package org.springframework.cloud.fn.consumer.tcp

Class TcpConsumerConfiguration

java.lang.Object

org.springframework.cloud.fn.consumer.tcp.TcpConsumerConfiguration

@Configuration(proxyBeanMethods=false)
@EnableConfigurationProperties({TcpConsumerProperties.class,TcpConnectionFactoryProperties.class})
public class TcpConsumerConfiguration
extends Object

A consumer that sends data over TCP.

Author:

Gary Russell, Christian Tzolov, Chris Bono

Constructor Summary

Constructors

Constructor	Description
TcpConsumerConfiguration(TcpConsumerProperties properties, TcpConnectionFactoryProperties tcpConnectionProperties)

Method Summary

Modifier and Type	Method	Description
org.springframework.cloud.fn.consumer.tcp.TcpConsumerConfiguration.TcpSendingMessageHandlerSmartLifeCycle	handler(org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory connectionFactory)
Consumer<Message<?>>	tcpConsumer(org.springframework.cloud.fn.consumer.tcp.TcpConsumerConfiguration.TcpSendingMessageHandlerSmartLifeCycle handler)
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 Details

TcpConsumerConfiguration

public TcpConsumerConfiguration(TcpConsumerProperties properties,
 TcpConnectionFactoryProperties tcpConnectionProperties)

Method Details

tcpConsumer

@Bean
public Consumer<Message<?>> tcpConsumer(org.springframework.cloud.fn.consumer.tcp.TcpConsumerConfiguration.TcpSendingMessageHandlerSmartLifeCycle handler)

handler

@Bean
public org.springframework.cloud.fn.consumer.tcp.TcpConsumerConfiguration.TcpSendingMessageHandlerSmartLifeCycle handler(@Qualifier("tcpSinkConnectionFactory")
 org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory connectionFactory)

tcpSinkConnectionFactory

@Bean
public org.springframework.integration.ip.config.TcpConnectionFactoryFactoryBean tcpSinkConnectionFactory(@Qualifier("tcpSinkEncoder")
 org.springframework.integration.ip.tcp.serializer.AbstractByteArraySerializer encoder,
 @Qualifier("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()