|
该版本仍在开发中，尚未被视为稳定。请使用最新的稳定版本，使用 Spring AMQP 4.0.0！ |
程序端点注册
RabbitListenerEndpoint提供一个兔子端点的模型，并负责为该模型配置容器。
基础设施允许你在被兔子听者注解。
以下示例展示了如何实现：
@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，这给出了实际的消息监听器调用，但你也可以自己构建端点变体来描述自定义调用机制。
这身份证财产是SimpleRabbitListenerEndpoint定义。 |
需要说明的是，你也可以跳过@RabbitListener一起，并通过程序化注册你的端点兔子听众配置器.