SpringBoot整合ActiveMQ开启持久化
2024-10-08 08:57:43
1.开启队列持久化
只需要添加三行代码
jmsTemplate.setDeliveryMode(2);
jmsTemplate.setExplicitQosEnabled(true);
jmsTemplate.setDeliveryPersistent(true);
2. 开启主题持久化,启动类添加如下配置
@Bean(name = "topicListenerFactory")
public JmsListenerContainerFactory<DefaultMessageListenerContainer> topicListenerFactory(ConnectionFactory connectionFactory){
DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory(); factory.setSubscriptionDurable(true);// Set this to "true" to register a durable subscription, factory.setClientId("B"); factory.setConnectionFactory(connectionFactory);
return factory; } //消费者消费 destination队列或者主题的名字
@JmsListener(destination = "boot_topic",containerFactory = "topicListenerFactory")
public void getMessage(TextMessage message,Session session) throws JMSException {
System.out.println("消费者获取到消息:"+message.getText());
}
这里需要注意,主题的数据不会被消费,会被一直记录下来,只能手动清除
最新文章
- SQL必备知识点
- MVC学习系列12---验证系列之Fluent Validation
- Java 源码解析之局部变量检查
- ZOOM - 简单易用的 jQuery 照片相册插件
- [Android Pro] AES加密
- Redis_Spring与Jedis的集成
- 五指CMS v1.2 GBK 发布下载
- Scala内部类
- vim编辑器的常见使用功能
- php防止浏览器点击返回按钮重复提交数据
- HBase rest
- DedeCMS清空删除所有文档后新建文档信息ID从1开始
- 了解多层交换中的CEF FIB CAM TCAM
- 2017-2018-2 20155303『网络对抗技术』Exp1:PC平台逆向破解
- Java关联关系、依赖关系
- JS读取json 文件
- Rscripts的使用,以及如何为R脚本传参数
- iOS系统中导航栏的转场解决方案与最佳实践
- Javascript继承机制的设计思想
- 【转载】iPhone屏幕尺寸、分辨率及适配