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

Question

我开始使用 SCS，我有以下用例：

1. 用户打开 HTTP 会话
2. 服务器根据用户安全属性动态确定要创建接收器侦听器的分区
3. 为用户会话创建了一个 Sink/Listener，并将其附加到通道分区。
4. 消息通过 http websocket 转发到浏览器客户端。
5. 当用户注销时，必须销毁通道上的监听器。

阅读参考文档并没有发现这种动态配置和生命周期管理的意义所在。关于如何实现这一目标的任何线索？

Answer 1

我也在关注这个。

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