io.pivotal.java.function.jdbc.supplier

Class JdbcSupplierConfiguration

java.lang.Object

io.pivotal.java.function.jdbc.supplier.JdbcSupplierConfiguration

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

Constructor Summary

Constructors

Constructor and Description
JdbcSupplierConfiguration(JdbcSupplierProperties properties, DataSource dataSource)

Method Summary

Modifier and Type	Method and Description
org.springframework.integration.core.MessageSource<Object>	jdbcMessageSource()
Supplier<org.springframework.messaging.Message<?>>	jdbcSupplier()
Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>>	splittedSupplier(Function<org.springframework.messaging.Message<?>,List<org.springframework.messaging.Message<?>>> splitterFunction)

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcSupplierConfiguration

public JdbcSupplierConfiguration(JdbcSupplierProperties properties,
                                 DataSource dataSource)

Method Detail

jdbcMessageSource

@Bean
public org.springframework.integration.core.MessageSource<Object> jdbcMessageSource()

splittedSupplier

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

jdbcSupplier

@Bean
 @ConditionalOnProperty(prefix="jdbc",
                       name="split",
                       havingValue="false")
public Supplier<org.springframework.messaging.Message<?>> jdbcSupplier()