Let's start with the architecture of our stock trading application. To set up an application that has a minimal level of complexity, we will create the following channels:
- An outgoing producer that's bound to the "stock-quote" channel, where messages containing stock orders will be written into a topic named "stocks"
- An incoming consumer that's bound to the "stocks" channel, which read messages that are available in the "stocks" topic
- An outgoing producer that's bound to the "in-memory-stream" channel, which broadcasts the new stock quote to all the available subscribers internally
- An incoming consumer that's bound to the "in-memory-stream" channel, which reads the new stock quote and sends it as SSE ...