Spring boot、Atomikos和ActiveMQ的Jms队列重新传递问题
Spring Boot是一个用于快速构建基于Spring框架的Java应用程序的开发框架。它简化了Spring应用程序的配置和部署过程，提供了一种约定优于配置的方式来开发应用程序。Spring Boot具有自动配置的特性，可以根据应用程序的依赖自动配置各种组件，大大减少了开发人员的工作量。
Atomikos是一个开源的事务管理器，用于在分布式环境中管理事务。它提供了可靠的分布式事务处理，支持多个资源管理器（如数据库、消息队列等）之间的事务协调和一致性。Atomikos可以确保在分布式系统中的各个资源上执行的操作要么全部成功，要么全部回滚，从而保证数据的一致性。
ActiveMQ是一个开源的消息中间件，实现了Java Message Service（JMS）规范。它提供了可靠的消息传递机制，支持点对点和发布/订阅模式，可以在分布式系统中实现异步通信和解耦。ActiveMQ具有高性能、可靠性和可扩展性，被广泛应用于企业级应用程序中。
Jms队列重新传递问题是指在使用JMS队列进行消息传递时，由于某种原因导致消息未能成功消费，需要重新传递消息的问题。解决这个问题的一种常见方法是使用消息重试机制，即在消息消费失败后，将消息重新放回队列中，等待下次消费。在Spring Boot中，可以通过配置重试策略和错误处理机制来实现消息的重新传递。
推荐的腾讯云相关产品和产品介绍链接地址：
- Spring Boot相关产品：腾讯云云服务器（https://cloud.tencent.com/product/cvm）和腾讯云容器服务（https://cloud.tencent.com/product/tke）。
- Atomikos和ActiveMQ相关产品：腾讯云消息队列CMQ（https://cloud.tencent.com/product/cmq）和腾讯云数据库TDSQL（https://cloud.tencent.com/product/tdsql）。
请注意，以上推荐的腾讯云产品仅供参考，具体选择应根据实际需求和情况进行评估。
相关·内容
1回答
Spring boot、Atomikos和ActiveMQ的Jms队列重新传递问题
spring、spring-boot、jms、activemq、atomikos
我正在尝试设置一个jms队列，并在事务失败的情况下具有重新传递行为。正在发生的情况是，消息被多次重新传递(和处理)，因为在消息处理代码之后，会话将关闭两次。第二次close尝试抛出错误，因为它已经关闭，因此事务被回滚并重新传递消息。activeMQXAConnectionFactory.setTrustedPackages(
new ArrayList<>(Arr
浏览 7提问于2018-02-06得票数 0
1回答
使用ActiveMq和Atomikos将JMS消息两次出队
jms、jta、spring-jms、atomikos
我使用ActiveMq作为JMS服务器，使用Atomikos作为事务管理器。有什么问
浏览 0提问于2012-02-29得票数 2
回答已采纳
1回答
spring-boot activemq日志过期消息
java、spring-boot、activemq
我有一个spring-boot简单的应用程序，我想记录过期的消息；在阅读了很多票据，阅读了很多教程之后，它不起作用。() to queue <" + myMessage + ">"); }这是我的队列使用者中<em
浏览 25提问于2020-03-12得票数 1
回答已采纳
1回答
ActiveMQ with JMS主题-使用者未将某些消息出队
activemq、spring-jms、atomikos、jms-topic
我们正在尝试使用ActiveMQ主题将JMS5.9.0设置为消息代理，但是我们在使用消息方面遇到了一些问题。
出于测试目的，我们有一个简单的配置:1个主题、1个事件生产者和1个消费者。我们可以看到在ActiveMQ管理控制台中发布到主题的所有消息，但它们永远不会到达使用者，即使我们重新启动应用程序(我们可以看到“入队”和“出队”列中的数字是不同的)。编辑:我还应该提到，当使用队列而
浏览 4提问于2014-01-12得票数 1
1回答
带有xa事务的Apache Camel路由、多个代理和控制总线
apache-camel
我有两个经纪人托管在不同的物理机器上。我需要编写camel路由，它将从broker-1的入站队列中获取消息&将其发送到broker-2中配置的出站队列。由于这将是一个分布式事务，所以我猜XA事务(Springboot Atomikos)需要使用&为了将流量转移到第三代理，需要使用控制总线eip。<dependency>
浏览 1提问于2021-01-29得票数 1
1回答
使用弹簧骆驼和原子库的ActiveMQ.Advisory.Consumer.Queue主题洪水
activemq、apache-camel、spring-jms、atomikos
想知道在使用Atomikos + Camel + ActiveMQ组合时，是否有人遇到过这个问题。我使用这个组合，以一种事务的方式从队列中剥离消息。看来效果很好。问题是，我现在的情况是，我需要在ActiveMQ中打开咨询信息。在我这样做之后，我注意到所有的队列都在不断地重新创建连接。ActiveMQ.Advisory.Consumer.Queue主题的泛滥证明了这一点。这在调试日志
浏览 9提问于2013-01-22得票数 2
1回答
执行JMS调用时的Spring异常
spring-boot、spring-jms、jta、activemq-artemis、atomikos
我在运行Pro Spring 5书籍中的一个示例时获得了JTA异常(12.使用Spring，boot-jms项目)。以下是整个代码(不包括导入)。在org.springframework.jms.UncategorizedJmsException:处理过程中发生了线程"main“中的异常；嵌套的异常是com.atomikos.jms.AtomikosTransactionRequiredJMSExcepti
浏览 5提问于2021-09-03得票数 0
1回答
ActiveMQ JMS事务未启动错误
spring、jms、activemq、xa、atomikos
情况是我们希望使用XA事务来协调ActiveMQ和Hibernate之间的活动( Server 2008)。我们正在使用：我们看到在与事务相关的日志文件中生成的以下错误尚未启动。这些总是与JMS相关的。这个问题更复杂，因为我们有3个web应用程序，它们使用相同的JMS队列</em
浏览 4提问于2011-06-03得票数 2
回答已采纳
1回答
在尝试恢复异常时使用spring-boot-starter jta-atomikos抛出错误
spring、spring-boot、activemq、atomikos
我使用的是spring(版本是1.4.1.RELEASE)，spring starter atomikos和activemq都是由autoconfig设置的，我还添加了连接池属性，如spring.jta.atomikos.connectionfactory.max-pool-size=15
# The minimum size of the poolspring<
浏览 5提问于2016-11-08得票数 0
回答已采纳
1回答
JMS未在Spring应用程序中启动
spring-boot、jms、activemq
我开发了一个spring引导应用程序，它使用JMS在Activemq中发送和侦听消息，但是在运行应用程序时，JMS还没有开始使用spring引导@SpringBootApplication=trueserver.port=8081<?> <parent>
浏览 1提问于2019-09-15得票数 0
回答已采纳
1回答
如何在Atomikos中使用JNDI创建apache camel XA连接
jms、apache-camel、jndi、xa、atomikos
下面是我的代码，我得到了不能写到类异常
<bean id="xa.amqConnectionFactory" class="org.apache.activemq.spring.ActiveMQXA
浏览 0提问于2015-08-24得票数 1
2回答
运输计划未获承认：[nsp]
jms、activemq、spring-jms
我试图连接到应用程序中的通用消息传递队列。这是我的Config课。<dependency> <artifactId>spring-boot-starter-activemq:784) ~[spring-boot-2.2.1.RELEASE.jar:2.2.1
浏览 3提问于2020-05-28得票数 2
回答已采纳
1回答
用于创建JMS接收器的框架
rabbitmq、jms、activemq、spring-jms
我想用Java创建一个JMS接收器/消费者，这是我第一次使用JMS。我想看一些我可以使用的例子和框架，但有点迷惑。你能告诉我下面的框架是否也有同样的作用吗？Spring JMSSpring JMS with ActiveMQ另外，还有其他好的框架吗？哪一个容易学习，哪一个性能更好？什么是Spring JMS
浏览 3提问于2017-06-27得票数 1
回答已采纳
1回答
使用JMS侦听器自动刷新Wicket组件
java、spring、jms、wicket、spring-jms
我正在尝试创建一个使用Wicket 7和Spring boot 1.5.3作为后端的通知面板。对于通知，我使用带有Spring boot 的JMS和ActiveMQ。我的问题是，如何在JMS侦听器收到消息后立即自动刷新(重新呈现/更新) wicket组件。
浏览 1提问于2017-06-19得票数 0
1回答
将Tomcat与ActiveMQ和Spring的DefaultMessageListenerContainer集成--重新传递JMS
tomcat、activemq、spring-integration、spring-jms
我有以下设置:带有嵌入式ActiveMQ的Tomcat
我使用Spring集成的JmsMessageDrivenChannelAdapter来创建适配器，它使用来自ActiveMQ队列的消息，如下所示：Jms.messageDrivenChannelAdapter(jmsConnectionFactory, TransactedMessageListenerContainer.class)broker将不会相应地重新传递</e
浏览 0提问于2016-05-25得票数 1
回答已采纳
1回答
如何在Mule XA事务中为ActiveMQ启用RedeliveryDelay
mule、activemq
我在Mule中有一个非常简单的流，它监听一个失败队列，如果队列中的消息包含字符串“ActiveMQ”，就会抛出一个异常。没有XA事务，一切都会正常工作。消息在5秒后重新发送，下一次在几秒后重新发送。在5次重新传递之后，消息被移动到死信队列。
对于XA事务，消息被立即重新传递5次，然后移动到死信队列。我怎样才能告诉Mule或ActiveMQ等待Re
浏览 2提问于2015-07-13得票数 3
1回答
XA资源已变为不可用XID引发-7
java、spring、spring-boot、transactions、atomikos
我正以一种随机的方式在错误之下。它最初不会抛出错误，但一段时间后就会抛出错误。一旦我重新启动服务器，一切都会被重置，错误也不会被抛出。XXXXAtomikosDataSource'：引发XID '31302E3137382E36382E3235302E746D30303031353030303138:31302E3137382E36382E3235302E746D3135‘的恢复<dependency>
<groupId>org.springframework.boot</
浏览 1提问于2018-03-20得票数 0
回答已采纳
1回答
一个Java项目中的队列和主题
java、spring、jms
我想在java Spring boot项目中使用JMS队列和主题。因此，对于主题，我必须在application.properties spring.jms.pub-sub-domain = true中使用此主题。现在在同一个项目中，我也想接收队列消息，购买ActiveMQ没有看到我的队列的任何消费者…我怎么才能让它工作呢？用于从ActiveMq本地主机发送邮件<
浏览 16提问于2016-08-29得票数 1
回答已采纳
2回答
在侦听器使用camel接收到JMS消息之前，如何延迟队列中的JMS消息？
jms、apache-camel
我正在尝试将消息在队列中延迟几秒钟。但是当我使用camel延迟选项时，它不是在队列中延迟，而是立即被消耗，并在路由路径中延迟。我们如何延迟消息，使它们在队列中停留几秒钟？我的带有驼峰配置的弹簧如下所示。<bean id="jms" class="org.apache.camel.component.jms.JmsComponent">
<property name="connectionFact
浏览 3提问于2015-11-05得票数 0
0回答
Spring boot自动配置EMS Tibco队列发送消息
spring-boot、jms、config、tibco-ems
我正在尝试使用Spring Boot向Tibco队列发送消息，我已经使用实现了这一点。它不使用Spring Boot内置的自动配置文件。谁能提供一个在application.properties文件中使用spring.jms.jndi-name-<JNDI name>、自动配置Spring Boot并发送消息的示例？我可以看到很多用于在Spring Boot</
浏览 14提问于2018-07-12得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频活动推荐
腾讯云开发者
