此版本仍在开发中,尚不被认为是稳定的。对于最新的稳定版本,请使用 Spring AMQP 3.2.6! |
容器管理
为注释创建的容器不会在应用程序上下文中注册。
您可以通过调用getListenerContainers()
在RabbitListenerEndpointRegistry
豆。
然后,您可以循环访问此集合,例如,停止或启动所有容器或调用Lifecycle
方法
在注册表本身上,这将调用每个容器上的作。
您还可以使用其id
用getListenerContainer(String id)
— 用于
例registry.getListenerContainer("multi")
对于上面代码段创建的容器。
从 1.5.2 版本开始,您可以获得id
已注册容器的值与getListenerContainerIds()
.
从 1.5 版开始,您现在可以分配一个group
到RabbitListener
端点。
这提供了一种机制来获取对容器子集的引用。
添加一个group
属性导致类型为Collection<MessageListenerContainer>
以组名称向上下文注册。
默认情况下,停止容器将取消使用者并在停止之前处理所有预提取的消息。
从版本 2.4.14、3.0.6 开始,您可以将forceStop
container 属性设置为 true 以在处理当前消息后立即停止,从而导致任何预提取的消息重新排队。
例如,如果使用独占或单活动使用者,这很有用。