jms 相关问题

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

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

如何在JMS中从消费者那里获取队列?

我有一个从浏览器获取队列的代码,但我找不到从消费者获取队列的方法。是否可以从消费者获取队列? 从浏览中获取队列的方法: 优先...

回答 1 投票 0

Quarkus 与 JPA / Hibernate Session 导致 JMS 线程中出现 ContextNotActiveException

我尝试从线程使用Panache存储库,该存储库不是由Quarkus“管理”的(因为我们使用ActiveMQ 5 JmsListeners,其中javax.jms.MessageConsumer在其自己的线程池中运行......

回答 1 投票 0

如何在ActiveMQ Artemis中查看消息的messageId?

我正在使用QueueBrowser从队列中获取消息,但无法获取messageId。由于某种原因我的 userId 显示 private void viewMessage() 抛出 NamingException、JMSException { ...

回答 1 投票 0

是否可以通过JMS从队列中获取所有消息而不将它们从队列中删除?

我想知道是否可以通过 JMS 从队列中获取消息而不删除它们。 JMX中有browse()方法,但是JMS中有类似的方法吗?

回答 1 投票 0

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