org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkConfiguration

@Configuration @EnableScheduling @EnableConfigurationProperties(PgcopySinkProperties.class) public class PgcopySinkConfiguration extends Object

Configuration class for the PostgreSQL CopyManager.

Constructor Details
- PgcopySinkConfiguration
  
  public PgcopySinkConfiguration()
Method Details
- pgcopyConsumer
  
  @Bean public Consumer<Message<?>> pgcopyConsumer(MessageHandler aggregatingMessageHandler)
- toSink
  
  @Bean public MessageChannel toSink()
- datasetSinkMessageHandler
  
  @Bean @ServiceActivator(inputChannel="toSink") public MessageHandler datasetSinkMessageHandler(JdbcTemplate jdbcTemplate, PlatformTransactionManager platformTransactionManager)
- nonBootDataSourceInitializer
  
  @ConditionalOnProperty("pgcopy.initialize") @Bean public DataSourceInitializer nonBootDataSourceInitializer(DataSource dataSource, ResourceLoader resourceLoader)
- jdbcTemplate
  
  @Bean public JdbcTemplate jdbcTemplate(DataSource dataSource)

Class PgcopySinkConfiguration

Nested Class Summary