我目前正在将消息传递到一个publish-subscribe-channel，该分配了一个task-executor，线程池中有 20 个消费者。
- 这些入站消息描述对实体的更新。
- 我们接连收到有关许多实体的更新
- 与同一实体相关的更新必须按排队顺序进行处理
显然，通过允许并发处理消息，这消除了消息处理顺序的保证。
允许并发处理不相关的消息，但确保对相关消息进行串行处理的适当拓扑是什么？
看起来这个调度员是我试图实现的一个例子