RabbitAdmin
code
- RabbitAdmin類能夠很好的操做RabbitMQ,在Spring中直接進行注入便可。
- 注意:autoStartup必需要設置爲true,不然Spring容器不會加載RabbitAdmin類
- RabbitAdmin底層實現就是從Spring容器中獲取Exchange、Binding、RoutingKey以及Queue的@Bean聲明
- 而後使用RabbitTemplate的execute方法執行對應的聲明,修改,刪除等一系列RabbitMQ基礎功能操做
- 例如:添加一個交換機,刪除一個綁定,清空一個隊列裏的消息等
@Bean public RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory){ RabbitAdmin rabbitAdmin = new RabbitAdmin(connectionFactory); rabbitAdmin.setAutoStartup(true); return rabbitAdmin; }
SpringAMQP
RabbitTemplate
SimpleMessageListenerContainer
MessageListenerAdapter
MessageConverter