spring-jms 相关问题

Spring提供了一个JMS集成框架,它简化了JMS API的使用,就像Spring对JDBC API的集成一样。

与 Spring Integration Flows 一起使用时如何处理关闭 ExecutorService?

我正在使用执行程序服务来确保传入的 jms 消息在将它们写入数据库后得到确认 - (使用 XA 数据源和分布式事务不是我们的选择...

回答 1 投票 0

Activemq 由于 NoClassDefFoundError 无法发送 JMS 消息

我的 activemq 应用程序遇到问题。启动后,如果我发送一条虚拟 JMS 消息到队列,它会抛出以下错误: org.springframework.web.util.NestedServletException:处理程序过程...

回答 1 投票 0

在Azure服务总线中,如何使用JMS将消息发送到带有“DeadLetterReason”的死信队列?

我正在使用 JMS 侦听器,使用 Java 语言和 Spring 框架围绕 Azure 服务总线构建服务。 我可以找到一种直接向 DeadLetterQueue 发送消息的方法,无需等待...

回答 1 投票 0

使用 Spring、Camel 和 Atomikos 进行 ActiveMQ.Advisory.Consumer.Queue 主题泛洪

我想知道是否有人在使用Atomikos + Camel + ActiveMQ Classic的组合时遇到过这个问题。我正在使用这个组合以事务处理方式从队列中剥离消息。它

回答 1 投票 0

让 JmsListenerContainerFactory 中的两个消费者顺序处理消息

我有一个使用以下参数实现 JmsListenerContainerFactory 的类: 工厂.setSessionTransacted(true); 工厂.setConcurrency(“1”); 工厂.setAutoStartup(true); 还有

回答 1 投票 0

JMSCC0111:JMS 的 IBM MQ 类尝试在 Connection 或 JMSContext 上设置预先存在的客户端 ID

即使在属性文件中指定订阅者客户端 ID 后,我仍看到以下错误。我正在使用 Spring Boot 3.3.4 2024-10-28T15:47:30.173-04:00 警告 14156 --- [(2)-10.1.81.174] o....

回答 1 投票 0

com.ibm.mq.MQException:MQJE001:完成代码 2,原因 2009 使用 Sprint Boot 和 JMS (IBM MQ )

我不确定我做错了什么,这个问题非常零星,我有下面的代码在IBM MQ上发送JMS消息。我正在单独使用 spring @async 进行操作,如下所示。 @覆盖 @异步

回答 1 投票 0

从 ActiveMQ Classic 升级到 ActiveMQ Artemis - 类 java.util.ArrayList 不是有效的属性类型

我正在将 ActiveMQ Classic 升级到 ActiveMQ Artemis,同时维护客户端代码。我有多个地方的代码看起来像这样。 导入java.io.IOException; 导入java.util.ArrayList; 导入java...

回答 1 投票 0

ActiveMQ Artemis 和 Spring JmsTemplate 的性能问题

在使用 ActiveMQ Artemis 代理和我的 Spring Boot 应用程序进行一些负载测试时,我遇到了性能问题。 我正在做的是发送例如每秒 12,000 条消息发送至...

回答 1 投票 0

带有 CachingConnectionFactory 和负载均衡器的 JmsTemplate

我正在使用 Spring 的 JmsTemplate、CachingConnectionFactory 和 JmsTransactionManager 来提交或回滚向 IBM MQ 发送消息。我有多个 MQ 主机,其顶部有一个负载均衡器

回答 1 投票 0

防止将 CachingConnectionFactory 与 DefaultJmsListenerContainerFactory 一起使用

我正在开发一个全新的项目,其中我需要有监听器来消费来自多个队列的消息(目前不需要生产者)。 从头开始,我用的是最后一个

回答 2 投票 0

在DefaultMessageListenerContainer中配置sessionAcknowledgeMode

我有一个设置,我必须从 ActiveMQ 代理中的队列中读取消息。读取消息后,我必须对该消息执行长时间运行的操作。 由于这个长时间运行的操作...

回答 3 投票 0

Sonic MQ 12.0 无法与 Spring Boot 3.3.1 版本连接

在最新版本的 Spring Boot 3.3.1 中使用 TopicConnectionFactory 创建 ConnectionFactory 时,progress.message.jclient 预计会遇到像 jakarta package 这样的问题。

回答 1 投票 0

我正在尝试在成功处理后手动确认消息

我目前使用的是 Spring Boot 版本 3.3.0 和 Java 21。 我在将 SessionAcknowledgeMode 设置为 Session.CLIENT_ACKNOWLEDGE 时遇到问题。我正在尝试手动确认消息...

回答 1 投票 0

缓存的 JMS Session 对象在 JmsTemplate 中打印为 null

我们的应用程序是一个在 Tomcat 内运行的 JAVA 后端应用程序。在较高级别上,它从 IBM MQ 读取输入,对其进行处理,将其保留在 ORACLE DB 中并将输出写入 MQ。这是一个分发...

回答 1 投票 0

Spring JMS 错误发送带有千分尺跟踪行李字段“X-Correlation-Id”的消息

我正在尝试使用 Spring JmsTemplate 发送 JMS 消息,如下所示。 jmsTemplate.convertAndSend(topicName, WebsocketMessage("")) 而且,我正在使用

回答 1 投票 0

大量带有选择器 JMSCorrelationID='CamelDummyJmsMessageSelector' 的异步消息使用者

我正在使用 apache Camel 使用 spring-jms 和 ibm-mq 配置 jms 请求/回复模式。 我的 Camel Route 配置为 InOut 模式,我能够成功地从回复队列中读取消息...

回答 1 投票 0

BackOff 和事务性不适用于消息处理,仅适用于侦听器设置

我有一个接收消息的 IbmMqEndpoint。我想要的是,如果在消息处理过程中发生错误,消息将保留在原始队列中。以下实施完美无缺...

回答 1 投票 0

org.springframework.messaging.converter.MessageConversionException:未找到从实际负载类型“byte[]”到预期负载的转换器

我有一个Spring Boot应用程序,在配置类中使用@EnableJMS,在侦听器类中使用@JMSListener 在配置类中,我创建了一个用于连接工厂的 bean 和一个用于混乱的 bean...

回答 2 投票 0

我可以更改 JMSMessageID 以保证其唯一吗?

我正在使用 JMS 构建 Spring Boot 应用程序。为了解决consumer端的重复消息问题,所有出队的JMSMessageID都会保存在redis中,consumer会ign...

回答 2 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.