Package org.springframework.cloud.fn.supplier.jdbc

Class JdbcSupplierConfiguration

java.lang.Object

org.springframework.cloud.fn.supplier.jdbc.JdbcSupplierConfiguration

@Configuration(proxyBeanMethods=false)
@EnableConfigurationProperties(JdbcSupplierProperties.class)
@Import(SplitterFunctionConfiguration.class)
public class JdbcSupplierConfiguration
extends Object

Author:

Soby Chacko, Artem Bilan

Constructor Summary

Constructors

Constructor	Description
JdbcSupplierConfiguration(JdbcSupplierProperties properties, DataSource dataSource)

Method Summary

Modifier and Type	Method	Description
org.springframework.integration.core.MessageSource<Object>	jdbcMessageSource(org.springframework.cloud.fn.common.config.ComponentCustomizer<org.springframework.integration.jdbc.JdbcPollingChannelAdapter> jdbcPollingChannelAdapterCustomizer)
Supplier<Message<?>>	jdbcSupplier(org.springframework.integration.core.MessageSource<Object> jdbcMessageSource)
Supplier<reactor.core.publisher.Flux<Message<?>>>	splittedSupplier(org.springframework.integration.core.MessageSource<Object> jdbcMessageSource, Function<Message<?>,List<Message<?>>> splitterFunction)

Methods inherited from class java.lang.Object

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

Constructor Details

JdbcSupplierConfiguration

public JdbcSupplierConfiguration(JdbcSupplierProperties properties,
 DataSource dataSource)

Method Details

jdbcMessageSource

@Bean
public org.springframework.integration.core.MessageSource<Object> jdbcMessageSource(@Nullable
 org.springframework.cloud.fn.common.config.ComponentCustomizer<org.springframework.integration.jdbc.JdbcPollingChannelAdapter> jdbcPollingChannelAdapterCustomizer)

splittedSupplier

@Bean(name="jdbcSupplier")
@PollableBean
@ConditionalOnProperty(prefix="jdbc.supplier",
                       name="split",
                       matchIfMissing=true)
public Supplier<reactor.core.publisher.Flux<Message<?>>> splittedSupplier(org.springframework.integration.core.MessageSource<Object> jdbcMessageSource,
 Function<Message<?>,List<Message<?>>> splitterFunction)

jdbcSupplier

@Bean
@ConditionalOnProperty(prefix="jdbc.supplier",
                       name="split",
                       havingValue="false")
public Supplier<Message<?>> jdbcSupplier(org.springframework.integration.core.MessageSource<Object> jdbcMessageSource)