@Configuration public class StreamConfiguration extends Object
| Constructor and Description |
|---|
StreamConfiguration() |
| Modifier and Type | Method and Description |
|---|---|
RecoveryStrategy<?> |
tapOnDestinationExpansionStrategy(StreamCompletionProvider streamCompletionProvider,
StreamDefinitionRepository streamDefinitionRepository,
StreamDefinitionService streamDefinitionService) |
@Bean @ConditionalOnMissingBean(value=TapOnDestinationRecoveryStrategy.class) public RecoveryStrategy<?> tapOnDestinationExpansionStrategy(StreamCompletionProvider streamCompletionProvider, StreamDefinitionRepository streamDefinitionRepository, StreamDefinitionService streamDefinitionService)
Copyright © 2022 Pivotal Software, Inc.. All rights reserved.