gst*_*low 5 java spring rabbitmq spring-jms spring-boot
我正在阅读有关如何启动 spring-jms 应用程序的官方入门文章
https://spring.io/guides/gs/messaging-jms/
@EnableJms 触发使用 @JmsListener 注释的方法的发现,在幕后创建消息侦听器容器。
但是我的应用程序看到@JmsListener没有@EnableJms注释的方法。
也许其他东西会迫使 spring 搜索@EnableJms方法。我想知道。
项目结构:
@Component
public class Listener {
@JmsListener(destination = "my_queue_new")
public void receive(Email email){
System.out.println(email);
}
@JmsListener(destination = "my_topic_new", containerFactory = "myFactory")
public void receiveTopic(Email email){
System.out.println(email);
}
}
Run Code Online (Sandbox Code Playgroud)
@SpringBootApplication
//@EnableJms I've commented it especially, behaviour was not changed.
public class RabbitJmsApplication {
public static void main(String[] args) {
SpringApplication.run(RabbitJmsApplication.class, args);
}
@Bean
public RMQConnectionFactory connectionFactory() {
return new RMQConnectionFactory();
}
@Bean
public JmsListenerContainerFactory<?> myFactory(DefaultJmsListenerContainerFactoryConfigurer configurer, ConnectionFactory connectionFactory) {
DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
// This provides all boot's default to this factory, including the message converter
configurer.configure(factory, connectionFactory);
// You could still override some of Boot's default if necessary.
factory.setPubSubDomain(true);
return factory;
}
}
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
6255 次 |
| 最近记录: |