org.springframework.cloud.dataflow.server.config.features

Class StreamConfiguration

java.lang.Object

org.springframework.cloud.dataflow.server.config.features.StreamConfiguration

@Configuration
 @ConditionalOnProperty(prefix="spring.cloud.dataflow.features",
                       name="streams-enabled",
                       matchIfMissing=true)
public class StreamConfiguration
extends Object

Author:

Ilayaperumal Gopinathan

Constructor Summary

Constructors

Constructor and Description
StreamConfiguration()

Method Summary

Modifier and Type	Method and Description
StreamDefinitionRepository	streamDefinitionRepository(DataSource dataSource)
StreamDeploymentRepository	streamDeploymentRepository(DataSource dataSource)
RecoveryStrategy<?>	tapOnDestinationExpansionStrategy(StreamCompletionProvider streamCompletionProvider, StreamDefinitionRepository streamDefinitionRepository)

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamConfiguration

public StreamConfiguration()

Method Detail

streamDefinitionRepository

@Bean
 @ConditionalOnMissingBean
public StreamDefinitionRepository streamDefinitionRepository(DataSource dataSource)

streamDeploymentRepository

@Bean
 @ConditionalOnMissingBean
public StreamDeploymentRepository streamDeploymentRepository(DataSource dataSource)

tapOnDestinationExpansionStrategy

@Bean
 @ConditionalOnMissingBean(value=TapOnDestinationRecoveryStrategy.class)
public RecoveryStrategy<?> tapOnDestinationExpansionStrategy(StreamCompletionProvider streamCompletionProvider,
                                                                                                                                            StreamDefinitionRepository streamDefinitionRepository)