Java消息服务(JMS)API是一种Java消息中间件(MOM)API,用于在两个或多个客户端之间发送消息。 JMS是Java平台企业版的一部分,由Java Community Process开发的规范定义。
我在从性能角度理解 JMS 方面遇到了一些困难。我们的应用程序中有这样非常简单的代码: QueueConnection 连接 = null; QueueSession 会话...
WSO2 ESB:在具有多个消息存储的消息处理器中处理重试和错误代码
我正在使用 WSO2 ESB 开发一个 API,其中我配置了两个消息存储和一个消息处理器。在我面临的场景中,消息处理器重试失败的消息最多 5 次,但我
ActiveMQ Artemis 通配符安全设置未按预期运行
在尝试设置一种良好且自动的方式来配置 ActiveMQ Artemis 用户时,我偶然发现了可以在安全设置块中使用的通配符路由。 利用这一点将使
使用带有 Vertex Broker 客户端的嵌入式 ActiveMQ 服务器进行测试
我正在将 ActiveMQ Artemis 与 Vertex Broker 客户端结合使用。我想测试下面的代码: 公共类 ActiveMqMessageSender { 私有字符串队列=“myQueue”; 公共无效发送消息(字符串
如何使用JMSToolBox以有限的权限连接ActiveMQ Artemis?
当我使用 JMSToolBox 连接到 ActiveMQ Artemis 2.x 代理时,它尝试创建一个具有非持久临时队列的地址,其名称是从 UUID 生成的。此时的安全设置...
Spring Boot 3.1 JMS 应用程序 - IBM MQ v9.3 (Linux) 中的“CodedCharSetId”未设置为 5026
我尝试将 MQMD 标头中的“CodedCharSetId”属性设置为 5026,以便从 Spring Boot 3.1 JMS 应用程序发送到 IBM MQ 服务器(v9.3,Linux)的消息。 这是我所做的:
无法将主题发送到 ActiveMQ Artemis:无法验证用户
我正在尝试让 ActiveMQ Artemis 在我的计算机上本地运行。 我创建了一个小程序(在 Spring Boot 应用程序中启动),它创建一个到 ActiveMQ Artemis 的 JMS ConnectionFactory,c...
Spring Boot 中 ActiveMQ Artemis 连接超时
我在 Spring Boot 中向 ActiveMQ Artemis 发送消息时遇到一些问题: JMS处理过程中发生未分类异常;嵌套异常是 ActiveMQConnectionTimedOutException[errorType=
如何验证使用 MUnit 测试在 Mule 4 JMS 发布中发送的 jms:properties?
我有以下 JMS 发布配置,我想验证在模拟连接器时是否使用给定值发送 prop1 和 prop2。 我有以下 JMS 发布配置,我想验证在模拟连接器时是否以给定值发送 prop1 和 prop2。 <jms:publish doc:name="Place file on some queue" sendCorrelationId="ALWAYS" persistentDelivery="true" config-ref="JMS_ActiveMQ_REF" destination="some.queue.name"> <jms:message correlationId="#[uuid()]"> <jms:properties><![CDATA[#[{ "prop1": vars.prop1, "prop2": vars.prop2 }]]]> </jms:properties> </jms:message> </jms:publish> 它被嘲笑使用: <munit-tools:mock-when doc:name="Mock Place file on some queue" processor=".*:.*"> <munit-tools:with-attributes> <munit-tools:with-attribute attributeName="doc:name" whereValue="#['Place file on some queue']" /> </munit-tools:with-attributes> <munit-tools:then-return> <munit-tools:payload value="#[payload]" mediaType="application/xml" /> </munit-tools:then-return> 以前在 Mule 3 中我会检查message.outboundProperties,但在 Mule 4 中则没有这个选项。 不幸的是,我无法通过搜索找到 Mule 4 解决方案,已知的 AI 也无能为力。 尝试在模拟中设置属性(除了有效负载之外)以匹配您在真实消息中观察到的内容。 示例: <munit-tools:then-return> <munit-tools:payload value="#[payload]" mediaType="application/xml" /> <munit-tools:attributes value="#[{ properties: { userProperties: { prop1: vars.prop1, prop2: vars.prop2 } } }]" /> </munit-tools:then-return>
这个问题是我之前问过的问题的后续。 设置与该问题中概述的相同,具有 4 个独立 ActiveMQ Artemis (v2.20) 节点的对称集群,...
我试图找到仅当消息数大于一定数量时才消费JMS队列中的消息的方法。 有任何想法吗? 通常如果您使用语法: 来自(“jms:开始曲...
需要有从kafka读取事务路由->保留在db中->发布到MQ。 所有这一切都应该在一个事务中发生,如果 DB 或 Commit to MQ/JMS 失败,那么 kafka 消息不应该是
Wildfly 无法在阴影 JAR WFNAM00026 中检索 TopicConnectionFactory:找不到 URI 的提供程序:null
我有一个连接到 Wildfly 27 实例的客户端应用程序。 要求之一是最终客户端是一个易于分发的可执行文件。 由 Windows 系统上的最终用户使用...
在我的应用程序中,我们使用 Solace MQ 并使用 HermesJMS 工具将消息发送到本地环境中的 MQ。 当我尝试向 MQ 发送批量消息时,出现下面提到的异常。我用Sp...
如何将数据从 BMC Remedy 推送到 Spring Boot 应用程序?
首先让我说我有零补救经验。 我们需要将数据从 Remedy 推送到 Spring Boot 应用程序。我看过很多很多例子,但似乎都与 Re...
JMS setMessageListener - 使用 JMSContext 不起作用
我有一个使用 ActiveMQ Classic 6.0.1 的简单生产者和消费者应用程序。 这是制作人: ConnectionFactory ConnectionFactory = new org.apache.activemq.ActiveMQConnectionFactory(BROKE...
JMS MessageProducer 不需要 Connection.start,但 MessageConsumer 需要
A - 问题 我知道有一个类似的问题,但在 SO 中不一样。 我试图了解 JMS 中 MessageProducer 和 MessageConsumer 的幕后情况。使用实施...
我正在使用 Spring 和 Jaxb 来监听 JMSQueue,然后将 JMS 消息解组到 java 对象中。然后我希望在我的 @JmsListener 端点上获取该 Java 对象。但相反,我...
目标“ReqQueue”的 JMS 消息侦听器调用程序设置失败
我的 springboot 应用程序正在使用来自 weblogic jms 队列(ReqQueue)的消息,并在处理后将响应发布回另一个队列(RespQueue)。 我最近升级了weblogic版本...
将选择器与 JMSMessageID 一起使用总是返回 null
这里我试图从队列中删除一条消息。但消息返回始终为空。即使提供的 jmsId 存在一条消息。 我在这里做错了什么。 注意:排队