jms 相关问题

在java中将JMS BytesMessage转换为String并在另一个进程中使用相同的bytesmessage

我的代码正在监听 IBM MQ。接收 JMS BytesMessage，将其转换为接收器类中的字符串，并将相同的 JMS BytesMessage 传递到另一个处理器类。处理器类别再次...

javax.jms.* 类的正确 Maven 依赖项是什么？

我需要导入 javax.jms.* 类。包含到 Maven 项目中的正确依赖项是什么？我正在尝试 javax.jms:jms:1.1，但没有运气（它是 pom，而不是 jar）。 附：我发现的唯一解决方法...

如何在Spring Boot中实现Oracle AQ队列？

我已经了解了如何使用 AQ（Streams？）包创建 Oracle 数据库。我还在 Oracle 中（手动）创建了一些队列。 （使用 PL/SQL 和 SQL）。 然而，我很难设置你...

在带有 JMS 的 ActiveMQ 的 Amazon MQ 中配置最大并发消息处理

我试图了解如何使用 ActiveMQ 引擎和 JMS 协议将 Amazon MQ 集成到我的应用程序中。主要目标是减慢某些进程并按顺序执行它们......

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

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

Weblogic 和 Websphere JMS 队列通信

当前在Weblogic中我们正在运行两个应用程序并通过JMS队列进行通信。现在我们正在将应用程序之一迁移到 Liberty Server。我们需要对 JMS 进行哪些配置

如何使用JMeter进行JMS性能测试？

我使用 @JmsListener 注释从 Azure 服务总线队列获取日志，然后将其保存到 Elasticsearch 中。 我需要使用JMeter进行性能测试。没有 http 端点。我……

“java.lang.IllegalStateException：无法在 Springboot 启动时从 ClassLoader 内省类 [com.app.api.config.JmsConfig]..”

我正在尝试在tomcat服务器上部署我的springboot应用程序，将其编译为.war，启动项目时收到以下错误 引起原因：java.lang.IllegalStateException：失败...

将 JMS 消息桥接到 Quarkus 中的 SSE 端点

在Spring项目中，我使用Sinks将事件发送到SSE端点，它运行良好，检查： https://github.com/hantsy/spring-graphql-sample/blob/master/dgs-subscription-sse/src/main/kotlin/com/example/

WildFly JMS 主题消费者收到空值

我正在使用 WildFly 19 和 JMS 主题应用程序。运行该程序后，它返回一个空值。 尝试 { 最终属性 env = new Properties(); env.put(Context.INITIAL_CONTEXT_FACTORY, &

Wildfy JMS 主题消耗空值

我正在使用 Wildfy 19 和 JMS（主题）应用程序。运行该程序后，它返回空值。 ` 尝试 { 最终属性 env = new Properties(); env.put(上下文。

WildFly JMS 错误：没有队列 jms.queue.exampleQueue 的权限='CONSUME'

我正在使用 WildFly 19 和 JMS 应用程序。运行该程序后，出现以下错误： AMQ229213：用户：murad 对地址上的队列 jms.queue.exampleQueue 没有权限='CONSUME'...

非阻塞 Jms 队列发送器

我想将日志/审核事件发布到 JMS 队列服务器。我实现了“QueueConnectActor”，它使用以下代码构造消息、创建队列并发送消息。 这使得阻塞校准...

使用 github.com/fmtn/a 将单个消息移动到不同的队列中

我有一个使用 ActiveMQ 5.13.4 的 JMS 设置，带有多个死信队列 (DLQ)，我想将特定消息从 DLQ 移回原始队列，以便我的应用程序可以再次处理它们...

JmsTemplate没有发送超时时间

我有使用 Spring 的 IBM MQ jar 配置的工作 JMS 应用程序 它适用于正确的队列信息，但是当我给出错误的队列信息时 它挂在 LOG.info("SEN...

如何处理jmsTemplate.receive无响应情况

我正在使用 jmsTemplate.receive("queueName") 从服务总线队列接收数据。 我将其用作 API 请求。 我面临的一个问题是，如果队列中没有剩余消息可供处理，那么它'...

JmsListener 监听通用容器对象

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

如何在ActiveMQ Artemis客户端中配置重投策略？

在ActiveMQ“Classic”附带的默认客户端中 org.apache.activemq:activemq-client:5.17.0 重新投递策略的配置如下 var 连接工厂 = 新

JMS 将消息发送给消费者子集

我的问题是，假设我们有 10 个消费者订阅了该主题。从生产者这边，我只需向 5 个消费者发送一条消息。 假设 5 个消费者拥有唯一的 id [1,2,3,4,5] 我...

如何在 JMS 中取消确认消息并将其发送回队列？

使用 JMS 从队列中读取/使用消息后，我想将相同的消息重新传递回队列，因为我想停止处理一段时间。如何才能实现这一目标？