Spring集成-聚合优先级通道 - 一点教程

提问者：小点点

Spring集成-聚合优先级通道

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

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

共1个答案

匿名用户

PriorityChannel对此没有帮助，但您可以在自定义ReleaseStrategy中做任何您想做的事情……

@FunctionalInterface
public interface ReleaseStrategy {

    boolean canRelease(MessageGroup group);

}

相关问题

热门标签

Java JavaScript Python PHP C# Android Html jQuery C++ Css IOS MySQL NodeJS