spring-jms 相关问题

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

我的两个接收器中只有一个正在从 ActiveMQ Artemis 多播队列接收消息

我有两个使用 JmsListener 的 Spring Boot 应用程序,它们从名为 onboard_application 的 ActiveMQ Artemis 多播队列和名为 onboard_address 的地址消费,但只有一个应用程序能够接收...

回答 1 投票 0

无法在 IntelliJ 中使用 ActiveMQ 启动监听器 Java 应用程序

我有一个侦听队列的 Java MQ 侦听器应用程序。当我在本地使用它时,我使用ActiveMQ发送消息,我的问题是: 我尝试在

回答 1 投票 0

mq-jms-spring-boot-starter 的 JNDI 连接问题

我正在使用 mq-jms-spring-boot-starter com.ibm.mq mq-jms-spring-boot-starter ...

回答 1 投票 0

@IntegrationFlow DSL 中的角色

使用消息驱动通道适配器时,是否可以通过 IntegrationFlow dsl 指定用于领导选举的端点角色? 我可以使用...创建 JMS 消息驱动端点...

回答 1 投票 0

从 ActiveMQ Artemis 队列重新传递 JMS 消息

我目前正在实现一个消费者,它监听 ActiveMQ Artemis Broker 发送的事件。 我发现这篇文章说: 1 & 2 和 3 & 4 之间的主要区别是...

回答 2 投票 0

使用 Artemis 队列重新传递 JmsEvent

我目前正在实现一个消费者,它监听 Artemis Broker 发送的事件。 我发现这篇文章说 1 & 2 和 3 & 4 之间的主要区别是后者允许

回答 2 投票 0

根据记录类型使 JMSTemplate 中的队列名称动态化

我在 Spring Batch 应用程序中使用 JSMItemWriter。 是否可以在运行时动态设置队列名称或者动态定义一个jmsTemplate,而不是在代码中将其定义为bean

回答 1 投票 0

Azure 服务总线:Amqp 空闲超时条件 = amqp:link:detach-forced

我得到的错误: 2019-12-09 06:39:33.189 错误 107132 --- [http-nio-8082-exec-5] o.a.c.c.C.[.[.[/].[dispatcherServlet] : servlet [dispatcherServlet] 的 Servlet.service()带有路径 [] 的上下文...

回答 3 投票 0

附加到服务激活器的 Spring Retry Recovery 不是处理链的一部分

我正在使用服务激活器的 Spring 集成链来处理来自队列的传入消息。持久化传入消息的服务激活器 messagePersister 之一。如果这是...

回答 1 投票 0

在 Spring Boot 测试中使用嵌入式 ActiveMQ Artemis 服务器创建会话工厂失败

尝试在 Spring Boot 中访问测试嵌入式 ActiveMQ Artemis 服务器时,遇到 jakarta.jms.JMSException: Failed to create session factory 错误。这是我的设置: 雅加达.jms.

回答 1 投票 0

Spring Jmstemplate.send 从 JmsListener 方法内部

在我们的应用程序中,我们有以下快乐路径流程: Gateway-> jmstemplate.send msg(withreplyTo=Gateway-Node-Specific_queue) 到 BE GenericQueue 并通过监听器等待响应 (Gateway-Node-

回答 1 投票 0

无法发布我的消息,出现反序列化未经授权的类错误

我正在尝试使用 RabbitMq 创建消息队列。当我尝试将消息推送到队列时,出现以下错误消息 org.springframework.amqp.rabbit.support.ListenerExecutionFailedException:

回答 2 投票 0

jakarta.jms.JMSException:无法从内容构建正文。可序列化的类不可用于代理

我在 Spring Boot 应用程序中遇到一个问题,无法显示 ObjectMessage 正文。我收到的错误消息是: jakarta.jms.JMSException:无法从内容构建正文。

回答 1 投票 0

Spring JmsTemplate - 添加自定义属性

我使用Spring API的JmsTemplate和MappingJackson2MessageConverter(版本:spring-jms-4.3.4.RELEASE.jar)来发布消息 到 ActiveMQ 主题,如下面的代码所示。 主题公开...

回答 2 投票 0

使用jms将消息发布到servicebus时令牌已过期

我们目前使用的技术有: Springboot(3.1.2) Azure 服务总线(主题) 春季JMS 我们按照 Spring 中的 jms 访问了 Azure 服务总线文档。如果您需要了解

回答 1 投票 0

如何从队列中消费不同类型的对象?

我有一个具有两种不同类类型的队列,即 BusinessUser 和 NormalUser。我怎样才能将它们转换为各自的类型? @JmsListener(目的地=“目的地”) 公共空间

回答 1 投票 0

ActiveMQ Artemis 主题监听器无法使用 Spring @JmsListener 接收消息

我有一个使用配置创建的主题 @豆 公共 ActiveMQTopic 示例主题(){ 返回新的 org.apache.activemq.artemis.jms.client.ActiveMQTopic("topic1"); } 听者

回答 1 投票 0

停止 Spring JMS 侦听器会导致 ActiveMQ Classic 上出现奇怪的行为

在启动和停止 JMS 侦听器时,我遇到了一些奇怪的行为。我已经定义了两个监听器,如下所示: @JmsListener(id="myid", 目的地 = "myDestination") 公开

回答 1 投票 0

ActiveMQ Classic 中分组消息的消耗存在较大延迟

我们有一个经纪人网络,由位于不同服务器上的三个经纪人组成。 网络连接器配置如下: 我们有一个经纪人网络,由位于不同服务器上的三个经纪人组成。 网络连接器配置如下: <networkConnectors> <networkConnector uri="static:(ssl://broker2:61616,ssl://broker3:61616)" networkTTL="5"/> </networkConnectors> 整体设置如下图所示。 在实践中,我们有时会看到特定客户端的消息消费存在较大延迟。在这种情况下,消息在最终被使用之前会被多次转发到其他代理。到目前为止,我们还无法找出可能的原因。 消费者不是很忙。它们是使用 Spring JMS 库实现的。每个经纪人的最小消费者数量为 3 个,但这可以根据需要自动扩展。 我们怀疑只有特定客户端受到影响的原因可能与我们使用 JMSGroupId 来获取消息处理方式的一些顺序有关。然而,我们没有确实的证据证明这一点。但它仍然无法解释为什么会发生这种情况。 我们还考虑向网络连接器添加以下参数,因为我们认为这可能会改善行为: dynamicOnly="true" decreaseNetworkConsumerPriority="true" suppressDuplicateQueueSubscriptions="true" 然而,这样做也很可怕,因为我们觉得我们不完全了解现在正在发生的事情,因此无法真正确定这些设置将对行为产生的影响。 我们怀疑只有特定客户受到影响的原因, 可能与我们使用 JMSGroupId 的事实有关 了解如何处理消息的一些顺序。 宾果游戏。 如果确保串行消息处理,则扩展消费者是没有用的。摆脱这种行为的最佳方法是设置一个专用的 JMS 队列,每个组有一个消费者,否则当队列中的多个后续消息属于同一组时,您将尝试消费者争用。 参见 JMS 拓扑(具有多个消费者的队列)和消息组

回答 1 投票 0

Spring Integration 和 JMS:从外部客户端接收消息

在我们的系统中,外部客户端将消息放入 JMS 队列中。 要求我们的 Spring Integration 应用程序从这些队列中获取消息并处理它们。 我最初的尝试...

回答 4 投票 0

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