@Configuration @ConditionalOnClass(value=org.springframework.cloud.stream.annotation.EnableBinding.class) @EnableBinding(value=TurbineStreamClient.class) public class TurbineStreamAutoConfiguration extends Object
turbine.stream.enabled
.Constructor and Description |
---|
TurbineStreamAutoConfiguration() |
Modifier and Type | Method and Description |
---|---|
HystrixStreamAggregator |
hystrixStreamAggregator(com.fasterxml.jackson.databind.ObjectMapper mapper,
rx.subjects.PublishSubject<Map<String,Object>> publisher) |
void |
init() |
@PostConstruct public void init()
@Bean public HystrixStreamAggregator hystrixStreamAggregator(com.fasterxml.jackson.databind.ObjectMapper mapper, rx.subjects.PublishSubject<Map<String,Object>> publisher)
Copyright © 2016 Pivotal Software, Inc.. All rights reserved.