Spring Integration - 聚合优先通道

Question

我在 Spring 集成中使用了 Aggregator，还看到了 PriorityChannel。是否有可能以某种方式使用其中两个来实现以下要求：

1. 从 RabbitMQ 接收消息并存储在具有聚合器的 spring 组件中
2. Aggregator 正在进行聚合，但同时它会根据一些复杂的排序算法优先发布消息。
3. 随着时间的推移，队列中的消息优先级可能会发生变化，我们需要能够在某个时间点重新安排优先级。

Answer 1

PriorityChannel 对此无济于事，但您可以在自定义 ReleaseStrategy 中做任何您想做的事情...

@FunctionalInterface
public interface ReleaseStrategy {

    boolean canRelease(MessageGroup group);

}