栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 面试经验 > 面试问答

使用ActiveMQ创建持久的主题和订户spring boot jms

面试问答 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

使用ActiveMQ创建持久的主题和订户spring boot jms

正如前面的答案所指出的,有必要在工厂设置客户端ID和持久订阅:

@Beanpublic DefaultJmsListenerContainerFactory jmsListenerContainerFactory() {    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();    factory.setConnectionFactory(connectionFactory());    factory.setDestinationResolver(destinationResolver());    factory.setConcurrency("3-10");    factory.setClientID("brokerClientId");    factory.setSubscriptionDurable(true);    return factory;}

但这本身并不能将客户端注册为持久订阅者,这是因为

JMSListener
需要
containerFactory
指定该客户端,否则它将采用默认值:

@JmsListener(destination = "venta.topic",id = "comercial",subscription = "venta.topic",//this was also needed with the same name as the bean abovecontainerFactory = "jmsListenerContainerFactory" )public void receiveMessage(Venta venta) { logger.log(Level.INFO, "RECEIVED : {0}",venta);       repository.save(venta);}

值得一提的是,这篇帖子使我意识到自己的错误。

我希望这会帮助别人



转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/615651.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号