Java消息服务(JMS)API是一种Java消息中间件(MOM)API,用于在两个或多个客户端之间发送消息。 JMS是Java平台企业版的一部分,由Java Community Process开发的规范定义。
我有 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 --...
如何通过JMS获取ActiveMQ Artemis队列中的LargeMessage?
我不知道如何使用 JMS 在 Artemis ActiveMQ 队列中获取 LargeMessage。我在Message类中没有找到任何get方法。有不同的方法来获取消息 ID、生命周期和
如何通过JMS获取ActiveMQ Artemis中的协议?
我正在向 Artemis ActiveMQ 队列发送消息,但我找不到获取消息协议的方法 接收消息正文的代码,但是在这个类中我没有找到
java.lang.ClassFormatError:类文件 javax/jms/JMSException 中非本机或抽象的方法中缺少代码属性
当我运行junit测试用例时,我遇到以下问题,类如下:; 公共类 RoeSubmissionBeanTest { RoeSubmissionBean roeSubmissionBean; 服务激活 serviceAct = 新
不稳定的 javax.jms.JMSException:同行已处置
我在使用 Java JMS 时遇到了不稳定的问题。 暂时工作正常,但会不规律地抛出以下异常并中断执行。 重要的是要注意,这种情况发生时不会停止...
如何在 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));
如何配置 WildFly 的 messages-activemq 子系统以使用服务器主机名而不是 IP 地址创建 JMS 连接?
我有一个在 WildFly 26.1.3 上运行的应用程序,我已确保该应用程序仅使用 HTTPS。除了由 messages-activemq 生成的 JMS 连接之外,我几乎已经解决了所有问题
我正在尝试使用 activemq 中的队列将虚拟主题中的消息出队。我尝试发送一些消息,它显示在“消息排队”下的主题中,但无法合并...
如何通过 JMS 获取 ActiveMQ Artemis 队列中的 permanentSize?
我不知道如何使用 JMS 获取 Artemis ActiveMQ 队列中的 persistSize。我在Message类中没有找到任何get方法。获取消息 ID、生命周期有不同的方法...
如何通过 JMS 获取 Artemis ActiveMQ 队列中的 persistSize?
我不知道如何使用 JMS 获取 Artemis ActiveMQ 队列中的 persistSize。我在Message类中没有找到任何get方法。获取消息 ID、生命周期有不同的方法...
我正在尝试在 JBoss 中部署和配置 DataStax Apache Pulsar JMS 客户端资源适配器,但出现以下错误: 2023-08-28 11:21:30,684 INFO [org.jboss.weld.deployer](MSC 服务...
如何通过JMS获取ActiveMQ Artemis中的JMSType?
我有代码可以查看消息并告诉我其类型(文本或字节)。我不明白为什么我的消息类型输出 null 而不是文本或字节 枚举 消息枚举 =
如何在 WebSphere MQ Series 中找到长时间运行的事务?
在J2EE环境中,WebSphere MQ服务器日志显示以下内容: 进程(954584.5) 用户(mqm) 程序(amqzmuc0) AMQ7469:事务回滚以释放日志空间。 .... 同时增加
我有一个从浏览器获取队列的代码,但我找不到从消费者获取队列的方法。是否可以从消费者获取队列? 从浏览中获取队列的方法: 优先...
Quarkus 与 JPA / Hibernate Session 导致 JMS 线程中出现 ContextNotActiveException
我尝试从线程使用Panache存储库,该存储库不是由Quarkus“管理”的(因为我们使用ActiveMQ 5 JmsListeners,其中javax.jms.MessageConsumer在其自己的线程池中运行......
如何在ActiveMQ Artemis中查看消息的messageId?
我正在使用QueueBrowser从队列中获取消息,但无法获取messageId。由于某种原因我的 userId 显示 private void viewMessage() 抛出 NamingException、JMSException { ...
是否可以通过JMS从队列中获取所有消息而不将它们从队列中删除?
我想知道是否可以通过 JMS 从队列中获取消息而不删除它们。 JMX中有browse()方法,但是JMS中有类似的方法吗?