spring-jms 相关问题

Spring 集成 JMS 轮询器以在轮询之间保留会话

我在 IBM MQ 系列队列上有一个 Spring Integration JMS 轮询器。当使用 IBM MQ Explorer（IBM 的基于 Eclipse 的队列浏览器应用程序）并查看队列的状态时，我看到了我的应用程序...

@Trace 注释中 metricName 的动态值？

我正在将 JmsListener 消耗的消息数据发送到 New Relic。我尝试了下面的代码 @Trace(dispatcher = true, metricName = "${jms.bulkUseruploadEventQueue.name}") @JmsListe...

如何检查 Solace 重播是否已完成并重新加入实时数据流

在我之前的问题中，我正在处理的代码库使用 Solace 的 JCSMP API 来触发重放，并使用 Spring JMS Listener 注解的方法来消费重放的事件。 我愿意...

设置ActiveMQ Artemis路由类型，Spring Boot JmsListener作为客户端

我使用 ActiveMQ Artemis 已经一年多了。到目前为止，我的要求是保留订单、电子邮件、供应商更新等消息。因此，我一直在明确创建一个地址...

JMS 侦听器中出现异常时重新传递 JMS 消息

org.springframework.jms.listener.AbstractMessageListenerContainer 的 Javadoc 指出，如果 “sessionAcknowledgeMode”设置为“CLIENT_ACKNOWLEDGE”：成功后自动消息确认...

如何在SQS上延迟4小时重试？

TL;DR：如何模仿rabbitMQ的调度功能来保持消费者： 无国籍的 无需管理预定消息 避免在接收之间从预定消息中进行无用的重试

Spring boot：java.lang.AbstractMethodError：接收器类org.springframework.jms.config.JmsListenerEndpointRegistry

运行 Spring Boot 应用程序时出现以下错误： java.lang.AbstractMethodError：接收器类org.springframework.jms.config.JmsListenerEndpointRegistry没有定义或继承

JMS Artemis DLQ 当 DLQ 上有活跃消费者时消息丢失

设置： 春季启动2.7.1 ActiveMQ Artemis（未嵌入） 每个队列的单独 DLQ 作为 ANYCAST。 除了我添加一个侦听 DLQ 的 @JmsListener 之外，该设置基本上工作正常。 ...

如何在 Spring Boot 中启动/停止@JmsListener

我正在尝试启动/停止从 JMS 队列检索消息。我尝试使用 JmsListenerEndpointRegistry 访问 stop() 和 start() 方法，但我无法使其工作。 这是

JmsListener 监听通用容器对象

我正在做一个基于事件的系统，它由通过某种领域事件进行通信的多个服务组成。所有服务都在 Spring Boot 3.1.3 上，并通过 activemq artemis 发送消息。 我走了...

使用 Spring Integration 在不同的 Spring Boot 应用程序之间发送 JMS 消息

我正在尝试使用 Spring 集成从一个 Spring Boot 应用程序（主程序）向另一个 Spring Boot 应用程序（工作程序）发送 Jms 消息。我使用嵌入式 ActiveMQ 作为代理。我已经做了以下...

Spring JMS MappingJackson2MessageConverter - 无法处理错误

我正在使用 Spring JMS，并且我正在使用 MappingJackson2MessageConverter 在各个组件之间传递消息。 我的核心问题是，当 MappingJackson2MessageConverter 经历...

使用 Spring Boot、JMS 和 ActiveMq 设置消息优先级

我尝试使用 Spring Boot 和 ActiveMQ 通过 JmsTemplate 发送不同优先级的消息，但它不起作用。 我试过这个： MessageCreator mc = 会话 -> { 短信...

使用 @JmsListener 处理 sendAndReceive 并仅发送

我有一个带有 @JmsListener 方法的 Spring 服务。它由客户端通过 JmsMessagingTemplate.convertSendAndReceive() 发送消息来调用。这很好用。 @服务 公开课

Spring 消息传递与不同包中的模型

这就是我正在尝试做的事情： 应用1（消费者） com. Producer.model.Event - 简单的可序列化模型（id，名称） 应用2（生产者） com.consumer.integration.model.Event - 简单

Spring Factory 创建监听队列的同步消费者

我是 Spring Boot 和大学项目工作编码的新手，我需要一些帮助。 我想创建一个 Spring Boot 应用程序，它启动一个工厂类，该工厂类将创建并启动 10 个同步......

从 JMS 中的监听器获取收据确认

我正在使用 Spring JMS 和 ActiveMQ 使用 JMS 主题（发布/订阅）将消息从发送者发送到多个侦听器。至此所有监听者都可以接收到来自发送者的消息。但我想打广告...

json 到对象转换期间出现异常：无法解析“javaTypes”中的“json__TypeId__”

我正在读取带有 json 消息的队列，并且在侦听器中我尝试将消息作为该 json 中的对象进行访问。这是使用的转换器： @Bean // 使用

Spring JMS DefaultMessageListenerContainer 轮询频率

我正在使用 DefaultMessageListenerContainer 来消费来自 ActiveMQ 队列的消息，如下所示。这个实现有没有轮询机制，监听器是否轮询队列看是否

无法在不同 Spring Boot 应用程序的不同端口上启动 2 个嵌入式 active-mq

我有 2 个 spring-boot 应用程序。每个应用程序都嵌入了活动的 mq 代理。 我需要让 2 个应用程序在同一台 PC 上并行工作，但现在不起作用。总是第一次申请