|
此版本仍在开发中，尚未被视为稳定版本。对于最新的稳定版本，请使用 Spring AMQP 3.2.0！ |
编程终端节点注册
RabbitListenerEndpoint提供 Rabbit 终端节点的模型，并负责为该模型配置容器。
基础设施允许您以编程方式配置终端节点，以及RabbitListener注解。
以下示例显示了如何执行此作：
@Configuration
@EnableRabbit
public class AppConfig implements RabbitListenerConfigurer {
@Override
public void configureRabbitListeners(RabbitListenerEndpointRegistrar registrar) {
SimpleRabbitListenerEndpoint endpoint = new SimpleRabbitListenerEndpoint();
endpoint.setQueueNames("anotherQueue");
endpoint.setMessageListener(message -> {
// processing
});
registrar.registerEndpoint(endpoint);
}
}在前面的示例中，我们使用了SimpleRabbitListenerEndpoint，它提供实际的MessageListener进行调用，但您也可以构建自己的终端节点变体来描述自定义调用机制。
应该注意的是，您也可以跳过使用@RabbitListener一起，并通过RabbitListenerConfigurer.