我有一个用例,我需要在运行时根据某些配置以编程方式启动侦听器。
我想知道如何在运行时注册 pulsar 监听器而不使用静态
@PulsarListener
注释。
谢谢你
目前的工作方式如下:
PulsarListenerAnnotationBeanPostProcessor
扫描所有 @PulsarListener
,对于每一个它......
PulsarListenerEndpointRegistrar
将端点注册到容器工厂PulsarListenerEndpointRegistry
注册端点和容器工厂这是一个更不常见的用例,因此没有内置支持在应用程序启动后动态注册容器/注册表。
但是,您可以创建自己的容器实例并通过手动启动/停止它们来自行处理生命周期方法(例如此处)。
我将在接下来的 24-48 小时内提供一个原型,详细介绍上述内容的几种变体,但希望快速为您提供上述初步信息。