jms 相关问题

Java消息服务(JMS)API是一种Java消息中间件(MOM)API,用于在两个或多个客户端之间发送消息。 JMS是Java平台企业版的一部分,由Java Community Process开发的规范定义。

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

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

回答 1 投票 0

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

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

回答 1 投票 0

IBM MQ 调用失败,代码为“2”(“MQCC_FAILED”),原因为“2009”(“MQRC_CONNECTION_BROKEN”)

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

回答 1 投票 0

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

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

回答 1 投票 0

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

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

回答 1 投票 0

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

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

回答 1 投票 0

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

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

回答 1 投票 0

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

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

回答 1 投票 0

如何通过JMS获取ActiveMQ Artemis队列中的LargeMessage?

我不知道如何使用 JMS 在 Artemis ActiveMQ 队列中获取 LargeMessage。我在Message类中没有找到任何get方法。有不同的方法来获取消息 ID、生命周期和

回答 1 投票 0

如何通过JMS获取ActiveMQ Artemis中的协议?

我正在向 Artemis ActiveMQ 队列发送消息,但我找不到获取消息协议的方法 接收消息正文的代码,但是在这个类中我没有找到

回答 2 投票 0

java.lang.ClassFormatError:类文件 javax/jms/JMSException 中非本机或抽象的方法中缺少代码属性

当我运行junit测试用例时,我遇到以下问题,类如下:; 公共类 RoeSubmissionBeanTest { RoeSubmissionBean roeSubmissionBean; 服务激活 serviceAct = 新

回答 1 投票 0

不稳定的 javax.jms.JMSException:同行已处置

我在使用 Java JMS 时遇到了不稳定的问题。 暂时工作正常,但会不规律地抛出以下异常并中断执行。 重要的是要注意,这种情况发生时不会停止...

回答 3 投票 0

如何在 JMS ActiveMQ Artemis 中获取字节消息的正文?

我有一个从 JMS 队列获取消息的代码,但我不明白如何获取消息正文(如果它是字节)并将其转换为字符串: 连接队列浏览器(); 枚举 我有一个从 JMS 队列获取消息的代码,但我不明白如何获取消息正文(如果它是字节)并将其转换为 String: connectQueueBrowser(); Enumeration<Message> messageEnumeration = queueBrowser.getEnumeration(); ArrayList<Message> messages = new ArrayList<>(); while (messageEnumeration.hasMoreElements()){ messages.add(messageEnumeration.nextElement()); } System.out.println(messages.get(0).getBody(String.class)); 这是我得到的错误: javax.jms.MessageFormatException: Body not assignable to class java.lang.String 但是当我显示正文消息时出现错误。 如果您发送了 JMS BytesMessage,那么您可以仅将 getBody 与 byte[].class 一起使用,例如: System.out.println(messages.get(0).getBody(byte[].class));

回答 1 投票 0

如何配置 WildFly 的 messages-activemq 子系统以使用服务器主机名而不是 IP 地址创建 JMS 连接?

我有一个在 WildFly 26.1.3 上运行的应用程序,我已确保该应用程序仅使用 HTTPS。除了由 messages-activemq 生成的 JMS 连接之外,我几乎已经解决了所有问题

回答 1 投票 0

虚拟主题中的消息未被消费者队列消费

我正在尝试使用 activemq 中的队列将虚拟主题中的消息出队。我尝试发送一些消息,它显示在“消息排队”下的主题中,但无法合并...

回答 2 投票 0

如何通过 JMS 获取 ActiveMQ Artemis 队列中的 permanentSize?

我不知道如何使用 JMS 获取 Artemis ActiveMQ 队列中的 persistSize。我在Message类中没有找到任何get方法。获取消息 ID、生命周期有不同的方法...

回答 1 投票 0

如何通过 JMS 获取 Artemis ActiveMQ 队列中的 persistSize?

我不知道如何使用 JMS 获取 Artemis ActiveMQ 队列中的 persistSize。我在Message类中没有找到任何get方法。获取消息 ID、生命周期有不同的方法...

回答 1 投票 0

如何在Jboss中部署pulsarra.rar?

我正在尝试在 JBoss 中部署和配置 DataStax Apache Pulsar JMS 客户端资源适配器,但出现以下错误: 2023-08-28 11:21:30,684 INFO [org.jboss.weld.deployer](MSC 服务...

回答 1 投票 0

如何通过JMS获取ActiveMQ Artemis中的JMSType?

我有代码可以查看消息并告诉我其类型(文本或字节)。我不明白为什么我的消息类型输出 null 而不是文本或字节 枚举 消息枚举 =

回答 1 投票 0

如何在 WebSphere MQ Series 中找到长时间运行的事务?

在J2EE环境中,WebSphere MQ服务器日志显示以下内容: 进程(954584.5) 用户(mqm) 程序(amqzmuc0) AMQ7469:事务回滚以释放日志空间。 .... 同时增加

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.