@Configuration @EnableConfigurationProperties(value=JdbcSupplierProperties.class) @Import(value=SplitterFunctionConfiguration.class) public class JdbcSupplierConfiguration extends Object
| Constructor and Description |
|---|
JdbcSupplierConfiguration(JdbcSupplierProperties properties,
DataSource dataSource) |
| 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) |
public JdbcSupplierConfiguration(JdbcSupplierProperties properties, DataSource dataSource)
@Bean public org.springframework.integration.core.MessageSource<Object> jdbcMessageSource()
@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)
@Bean
@ConditionalOnProperty(prefix="jdbc",
name="split",
havingValue="false")
public Supplier<org.springframework.messaging.Message<?>> jdbcSupplier()
Copyright © 2020 Pivotal Software, Inc.. All rights reserved.