Java消息服务(JMS)API是一种Java消息中间件(MOM)API,用于在两个或多个客户端之间发送消息。 JMS是Java平台企业版的一部分,由Java Community Process开发的规范定义。
Jakarta JMS Spring-boot 立即发送消息
我需要发送一些消息而不等待交易结束。 但我尝试过的所有设置都喜欢 template.setSessionTransacted(false);并且设置不同的确认模式并没有带来任何结果。 ...
是否可以通过Jolokia JMX从ActiveMQ Artemis获取单条消息?
我尝试通过 Jolokia JMX 从 Artemis 获取一条消息,但找不到过滤 JMSMessageID 的方法。 代理版本:红帽 AMQ 7.11.7 目前我最好的尝试是: https://经纪商/控制台/
是否可以通过 Jolokia JMX 从 Artemis 获取单条消息?
我尝试通过 Jolokia JMX 从 Artemis 获取一条消息,但找不到过滤 JMSMessageID 的方法。 经纪商版本:7.11.7 我目前最好的尝试是 https://broker/console/jolokia/ex...
Spring Integration & MQ 中设计超时处理
我正在开发一个正在重组为一致异步的应用程序。它过去是,现在仍然是基于 Spring Integrations。作为支付网关,我可以参考ISO 20022标准...
在我的 Java Spring Boot 3 应用程序中,我有一个用于 Oracle AQ 的简单 JmsListener: 导入 com.example.webfluxexample.model.MessageInfo; 导入 jakarta.jms.Message; 导入 jakarta.jms.ObjectMessage; 我...
在Azure服务总线中,如何使用JMS将消息发送到带有“DeadLetterReason”的死信队列?
我正在使用 JMS 侦听器,使用 Java 语言和 Spring 框架围绕 Azure 服务总线构建服务。 我可以找到一种直接向 DeadLetterQueue 发送消息的方法,无需等待...
Active MQ 与 JBoss Messaging [已关闭]
我将为一个项目选择一个 JMS 消息代理。 JMS 服务器稳定并且能够处理高负载的消息至关重要。我已经缩小了列表范围以包括 Active MQ 和...
Azure 服务总线和 Azure 容器应用程序 - 重新部署失败,因为已经有一个客户端针对该主题使用 tha sub
我有一个(WildFly 33 上的 Java 21/EE10)容器,它使用 JMS 2.0(因此是 ESB 高级层)连接到 Azure 服务总线。 一切都很好。 但是,当重新部署(甚至重新启动)POD 时,@St...
如何解决 IBM MQ 调用失败,代码为“2”(“MQCC_FAILED”)原因“2035”(“MQRC_NOT_AUTHORIZED”)
我有一个 Spring 项目,我需要连接到 IBM MQ 来发送和接收消息,但出现以下异常:- IBM MQ 调用失败,代码为“2”(“MQCC_FAILED”),原因为“2035” ('
一些遗留代码在使用 JMS 类连接到 MQ 的大型机上运行。 旧版本使用 Java 8、带有 Spring 5 的 Java EE 和 IBM 提供的 JAR:com.ibm.mq.jar、com.ibm.mq.jmqi.jar、c...
我正在使用 Payara 5.2022.5 公共无效resubmitMessages(布尔resubmitAll)抛出异常{ log.debug("DLQService: resubmitMessages()"); 初始上下文 ctx = null;
无法从 Payara 5.2022.5 上的 DLQ 获取现有 JMS 消息
我正在尝试重新处理来自死信/消息队列(DLQ)的消息。 在下面的方法中,当我在 Payara 5.2022.5 上执行 dlqConsumer.receive(5000) 时,我得到 null。 当我使用
ClassNotFoundException:ACtiveMQ 5.8 中的 KahaPersistenceAdapter
我将应用程序从 ActiveMQ 5.5.1 迁移到 ActiveMQ 5.8.0。 我的应用程序在 activemq.xml 文件中具有持久性配置,如下所示: <
让 JmsListenerContainerFactory 中的两个消费者顺序处理消息
我有一个使用以下参数实现 JmsListenerContainerFactory 的类: 工厂.setSessionTransacted(true); 工厂.setConcurrency(“1”); 工厂.setAutoStartup(true); 还有
我们使用 Quarkus Messaging(带有“smallrye-jms”扩展,以便连接到 IBM MQ)和转换器,将字符串中接收到的消息转换为 Java 对象。 收到时...
无法通过 JMX 远程连接嵌入式 ActiveMQ Artemis
我使用嵌入式ActiveMQ Artemis 2.38.0进行测试。我创建了嵌入式 ActiveMQ Artemis,如下所示: 配置 mqConfig = new ConfigurationImpl(); 服务器=新的EmbeddedActiveMQ(); mqConfig。
无法远程连接 JMX 进行嵌入式 ActiveMQ Artemis 管理,ActiveMQ Artemis 2.38.0
我使用嵌入式ActiveMQ Artemis 2.38.0进行测试。我创建了嵌入式 ActiveMQ Artemis,如下所示: 配置 mqConfig = new ConfigurationImpl(); 服务器=新的EmbeddedActiveMQ(); mqConfig。
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....
com.ibm.mq.MQException:MQJE001:完成代码 2,原因 2009 使用 Sprint Boot 和 JMS (IBM MQ )
我不确定我做错了什么,这个问题非常零星,我有下面的代码在IBM MQ上发送JMS消息。我正在单独使用 spring @async 进行操作,如下所示。 @覆盖 @异步