jms 相关问题

使用IBM的SDK从独立客户端访问WildFly的ActiveMQ

正如标题所示，我正在尝试从独立客户端连接到在 WildFly 10 上运行的 ActiveMQ。如果我使用 Oracle 的 SDK，无需更改代码或配置，我就可以连接，但是...

来自 Java SE 的 JMS 连接

我想以与代理无关的方式从 Java SE 应用程序创建 JMS 连接。 我正在将 JDBC 与其用于数据库连接的 URL 方案进行比较。这创造了独立于...

如何将外部消息代理添加到Wildfly？

我正在使用 WildFly 部署 EJB 战争，该战争使用外部消息代理（即 Apollo），而不是 WildFly 附带的消息代理（即 ActiveMQ Artemis）。 我必须做什么来设置 JNDI 配置...

长链路RMQ集群

抱歉，对于某些人来说，这似乎是一个简单的问题，但我们目前使用 RMQ 进行非常简单的客户端/队列/消费者类型事务。有些使用返回消息队列，而另一些则只是简单...

使用 Spring Boot 将消息发送到 JMS 队列

我是 Spring JMS 的新手。我的应用程序是使用 Spring Boot 开发的，并部署在 JBoss EAP 7.2.0 中。我有一个远程队列，它是一个 ActiveMQ Artemis 队列，也嵌入在 JBos 中...

无法通过 Wildfly 10 中的默认 Artemis/ActiveMQ 向本地 JMS 队列发送消息

使用 Wildfly 10.1.0.Final 和自定义 JMS 消息队列，我可以通过 JNDI 名称 java:/ConnectionFactory 成功通过虚拟机内 InVmConnectionFactory 发送和接收消息。 然而，我...

如何在ActiveMQ Artemis中获取队列长度？

我有一个代码可以获取队列长度，但是是在浏览方法上。如何通过 JMS 获取队列长度？如果不是通过 JMS，那么也许通过另一个包中的其他类？ ...

Spring Boot 应用程序将 Kafka 与 JMS 集成

我正在尝试构建一个 Spring Boot 应用程序，该应用程序从 Kafka 读取消息并通过 JMS 发送消息，反之亦然（从 JMS 读取并写入 kafka）。但是，我没有找到任何有用的 Jumpstar 教程...

是否可以让 Gattle JMS 仅监听消息？

我一直在探索使用 Gattle 进行 JMS 测试，作为更广泛的 AUT 性能测试的一部分。我已经玩过 https://gadling.io/docs/current/jms/ 中的示例，并且成功了...

主题的 JMS 单出队

我有很多订阅者正在收听一个主题，但只有一个订阅者收到消息（出队）来处理任务。 我可以选择主题和非持久订阅者吗？ 以下陈述是否正确...

如何使用 Spring JmsListener 手动确认消息

我正在将 JMS 与 Spring 的 JmsListener 一起使用。我能够使用来自 JMS 队列的消息，但它使用的是 AUTO_ACKNOWLEDGE。如何设置 CLIENT_ACKNOWLEDGE 以便我可以使用其他消息...

功能完成后消耗 JMS 消息

使用 MessageListener 从队列中消费消息后，它不会立即从队列中获取另一条消息。它正在等待我的功能完成，然后收到另一条消息...

当接收器不可用时 JMS 消息丢失

我正在使用 JMS 进行消息传递。当发送者和接收者都可用时，我成功收到了消息。但是当我关闭接收器并重新启动时，未收到排队的消息

如何批量读取重新投递队列？

我使用 ActiveMQ classic 作为队列管理器。我的消息使用者（使用 Spring 的 @JmsListener）写入 MongoDB。如果 MongoDB 不可用，那么它会将消息发送到不同的队列，让我们...

IBM MQ 调用失败，代码为“2”（“MQCC_FAILED”），原因为“2009”（“MQRC_CONNECTION_BROKEN”）

我收到此错误，直到该主题没有发布者为止。一旦有发布者并且消息开始在该主题上发布，JMS 侦听器就会积极侦听并且......

IBM MQ 持久事务和非持久事务之间的根本区别是什么？

在测试使用 IBM Websphere MQ 的应用程序时，我在 MQ 中提交消息时遇到了问题。 基本上有一个批次从 Oracle DB 读取并处理

Seedstack JMS 侦听器从属性文件启用禁用

我有 4 个 JMS 监听器类。有时我需要停止侦听器（例如，如果附加到该侦听器的队列不起作用）。有什么方法可以使用 som 停止属性文件中的侦听器...

如何通过JMS获取ActiveMQ Artemis代理队列中的消息属性？

我有一个获取属性名称_AMQ_LARGE_SIZE的代码，但我不明白如何获取所有标头。 ArrayList 消息 = new ArrayList<>(); 枚举属性Nam...

如何在 Spring Boot 中使用 JMS 和 ActiveMQ“经典”发送自定义对象？

我正在尝试使用 ActiveMQ“Classic”发送 ObjectMessage。为此，我创建了两个 Spring Boot 项目 - 客户和生产者。我使用下面的代码从生产者发送。 @

单个数据库上的分布式事务处理（SpringBoot、JMS、JPA）

我有一个设置，可以通过添加侦听 JMS 队列的节点来扩展该设置。 所有资源（节点）写入同一数据库并并行处理一项或多项“作业”。 工作 A --...