程序端点注册
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一起,并通过程序化注册你的端点兔子听众配置器.