编程方式注册端点

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 以编程方式注册您的端点。