@Configuration @EnableBinding(value=org.springframework.cloud.stream.messaging.Processor.class) @EnableConfigurationProperties(value=CounterProcessorProperties.class) @Import(value=org.springframework.cloud.stream.app.analytics.common.CounterCommonConfiguration.class) public class CounterProcessorConfiguration extends Object
Constructor and Description |
---|
CounterProcessorConfiguration() |
Modifier and Type | Method and Description |
---|---|
Object |
evaluate(org.springframework.messaging.Message<?> input) |
@StreamListener(value="input") @SendTo(value="output") public Object evaluate(org.springframework.messaging.Message<?> input)
Copyright © 2020 Pivotal Software, Inc.. All rights reserved.