@Configuration @ConditionalOnProperty(prefix="spring.cloud.dataflow.features", name="streams-enabled", matchIfMissing=true) public class StreamConfiguration extends Object
Constructor and Description |
---|
StreamConfiguration() |
Modifier and Type | Method and Description |
---|---|
StreamDefinitionRepository |
streamDefinitionRepository(DataSource dataSource) |
RecoveryStrategy<?> |
tapOnDestinationExpansionStrategy(StreamCompletionProvider streamCompletionProvider,
StreamDefinitionRepository streamDefinitionRepository) |
@Bean @ConditionalOnMissingBean public StreamDefinitionRepository streamDefinitionRepository(DataSource dataSource)
@Bean @ConditionalOnMissingBean(value=TapOnDestinationRecoveryStrategy.class) public RecoveryStrategy<?> tapOnDestinationExpansionStrategy(StreamCompletionProvider streamCompletionProvider, StreamDefinitionRepository streamDefinitionRepository)
Copyright © 2017 Pivotal Software, Inc.. All rights reserved.