The processor application will pick up the message from the input channel on the message broker. It will process the message and put it out on the output channel of the message broker. In this specific example, processing involves adding the position of current holdings to the message.
Let's use Spring Initializr (https://start.spring.io) to set up the application. Provide the details listed here and click on Generate Project:
- Group: com.mastering.spring.cloud.data.flow
- Artifact: stock-intelligence-processor
- Dependencies: Stream Rabbit
Update the SpringBootApplication file with the following code:
@EnableBinding(Processor.class)@SpringBootApplication public class StockIntelligenceProcessorApplication { private static Logger logger ...
