spring-cloud-stream - Spring Cloud Stream动态接收器监听器

我开始使用SCS，并且有以下用例:

用户打开HTTP session

服务器根据用户安全属性

动态找出要向其创建接收器侦听器的分区

创建一个特定于用户 session 的接收器/监听器，并将其附加到通道分区。

消息通过http websocket转发到浏览器客户端。

用户注销时，必须销毁通道上的侦听器。

阅读参考文档表明，这种动态配置和生命周期管理毫无意义。关于如何实现这一目标的任何线索？

最佳答案

我也在寻找这个。

现在，我可以使用BinderAwareChannelResolver创建动态生产者。但是不幸的是，我还没有在动态的消费者身上找到任何东西。