Programmatic Endpoint Registration

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 对端点进行编程注册。