org.springframework.cloud.fn.supplier.syslog

Class SyslogSupplierConfiguration

java.lang.Object

org.springframework.cloud.fn.supplier.syslog.SyslogSupplierConfiguration

@Configuration
 @EnableConfigurationProperties(value=SyslogSupplierProperties.class)
public class SyslogSupplierConfiguration
extends Object

Configuration class for SYSLOG Supplier.

Author:

Soby Chacko

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	SyslogSupplierConfiguration.BothBits
protected static class	SyslogSupplierConfiguration.TcpBits

Constructor Summary

Constructors

Constructor and Description
SyslogSupplierConfiguration()

Method Summary

Modifier and Type	Method and Description
org.springframework.integration.syslog.MessageConverter	syslogConverter()
org.springframework.integration.channel.FluxMessageChannel	syslogInputChannel()
Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>>	syslogSupplier(org.springframework.beans.factory.ObjectProvider<org.springframework.integration.syslog.inbound.UdpSyslogReceivingChannelAdapter> udpAdapterProvider, org.springframework.beans.factory.ObjectProvider<org.springframework.integration.syslog.inbound.TcpSyslogReceivingChannelAdapter> tcpAdapterProvider)
org.springframework.integration.syslog.inbound.TcpSyslogReceivingChannelAdapter	tcpAdapter(org.springframework.integration.ip.tcp.connection.AbstractServerConnectionFactory connectionFactory)
org.springframework.integration.syslog.inbound.TcpSyslogReceivingChannelAdapter	tcpBothAdapter(org.springframework.integration.ip.tcp.connection.AbstractServerConnectionFactory connectionFactory)
org.springframework.integration.syslog.inbound.UdpSyslogReceivingChannelAdapter	udpAdapter()
org.springframework.integration.syslog.inbound.UdpSyslogReceivingChannelAdapter	udpBothAdapter()

Methods inherited from class java.lang.Object

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

Constructor Detail

SyslogSupplierConfiguration

public SyslogSupplierConfiguration()

Method Detail

syslogInputChannel

@Bean
public org.springframework.integration.channel.FluxMessageChannel syslogInputChannel()

syslogSupplier

@Bean
public Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>> syslogSupplier(org.springframework.beans.factory.ObjectProvider<org.springframework.integration.syslog.inbound.UdpSyslogReceivingChannelAdapter> udpAdapterProvider,
                                                                                                            org.springframework.beans.factory.ObjectProvider<org.springframework.integration.syslog.inbound.TcpSyslogReceivingChannelAdapter> tcpAdapterProvider)

udpAdapter

@Bean
 @ConditionalOnProperty(name="syslog.supplier.protocol",
                       havingValue="udp")
public org.springframework.integration.syslog.inbound.UdpSyslogReceivingChannelAdapter udpAdapter()

udpBothAdapter

@Bean
 @ConditionalOnProperty(name="syslog.supplier.protocol",
                       havingValue="both")
public org.springframework.integration.syslog.inbound.UdpSyslogReceivingChannelAdapter udpBothAdapter()

tcpAdapter

@Bean
 @ConditionalOnProperty(name="syslog.supplier.protocol",
                       havingValue="tcp",
                       matchIfMissing=true)
public org.springframework.integration.syslog.inbound.TcpSyslogReceivingChannelAdapter tcpAdapter(@Qualifier(value="syslogSupplierConnectionFactory")
                                                                                                                                                                                                                                                       org.springframework.integration.ip.tcp.connection.AbstractServerConnectionFactory connectionFactory)

tcpBothAdapter

@Bean
 @ConditionalOnProperty(name="syslog.supplier.protocol",
                       havingValue="both")
public org.springframework.integration.syslog.inbound.TcpSyslogReceivingChannelAdapter tcpBothAdapter(@Qualifier(value="syslogSupplierConnectionFactory")
                                                                                                                                                                                                                org.springframework.integration.ip.tcp.connection.AbstractServerConnectionFactory connectionFactory)

syslogConverter

@Bean
public org.springframework.integration.syslog.MessageConverter syslogConverter()