I have an environment with one producer and a number of consumers.
The producer creates 2 types of messages:
- A message that needs to be processed by ONE consumer only (any consumer will do).
- A message that needs to be processed by ALL consumers.
How can this be implemented?
For message type 1, a work queue is the suitable model.
For message type 2, a fanout/direct/routing/topic are suitable.
But how do I combine them?