编程方式的端点注册

RabbitListenerEndpoint 提供了 Rabbit 端点的模型,并负责为该模型配置容器。除了通过 RabbitListener 注解检测到的端点外,该基础设施还允许您以程序方式配置端点。以下示例展示了如何实现:

@Configuration
@EnableRabbit
public class AppConfig implements RabbitListenerConfigurer {

    @Override
    public void configureRabbitListeners(RabbitListenerEndpointRegistrar registrar) {
        SimpleRabbitListenerEndpoint endpoint = new SimpleRabbitListenerEndpoint();
		endpoint.setId("someRabbitListenerEndpoint");
        endpoint.setQueueNames("anotherQueue");
        endpoint.setMessageListener(message -> {
            // processing
        });
        registrar.registerEndpoint(endpoint);
    }
}

在前面的示例中,我们使用了 SimpleRabbitListenerEndpoint,它提供了要调用的实际 MessageListener,但您也可以构建自己的端点变体来描述自定义调用机制。

id 属性对于 SimpleRabbitListenerEndpoint 定义是必需的。

应该注意的是,您可以完全跳过使用 @RabbitListener,并通过 RabbitListenerConfigurer 以程序方式注册您的端点。

© . This site is unofficial and not affiliated with VMware.