Apache ActiveMQ是一个开源(Apache 2.0许可)消息代理,它完全实现了Java Message Service 1.1(JMS)。它提供了“企业功能”,如群集,多个消息存储,以及将任何数据库用作除VM,缓存和日志持久性之外的JMS持久性提供程序的能力。
代码 尝试 { $stomp = new Stomp('tcp://xx:xxx:xxx:xxx:61616','admin','admin'); // 连接到远程服务器 } catch(StompException $e) { die('连接失败:' . $e->getMessage()...
如何检查 ActivemQ“Classic”上是否存在队列?
我有这个方法,当数据队列不存在时会抛出异常,但实际上并不存在。你还有其他办法解决这个问题吗? public void checkDataQueue(String dataQueue) 抛出 JMSException ...
如何使用ActiveMQ“经典”获取JMS中CompletionListener类的功能?
我在 JMS 应用程序中使用 ActiveMQ“经典”,这是一个简单的聊天应用程序,我希望在成功发送消息时收到通知。如果失败那么原因...
message.acknowledge() 在使用 Spring Boot 在 ActiveMQ 中读取消息后不会将消息出队
我正在尝试使用 Spring Boot 和 ActiveMQ Classic 按队列内容中的 id 读取队列,然后将它们出列。 为此,我创建了以下代码。代码从响应中提取队列
如何在 Spring Boot 中使用 JMS 和 ActiveMQ“经典”发送自定义对象?
我正在尝试使用 ActiveMQ“Classic”发送 ObjectMessage。为此,我创建了两个 Spring Boot 项目 - 客户和生产者。我使用下面的代码从生产者发送。 @
我是 Java 新手,正在编写一个连接到 ActiveMQ 集群的微服务。当我使用一个代理 IP 地址时,我可以连接到集群并成功读取消息。然而,
重复日志:警告到 tcp 的传输连接:<ip>失败:java.net.SocketException:连接重置
我正在本地计算机上运行 ActiveMQ 5.9.0 版本以用于开发目的(Windows 7)。我使用 AMQP 作为协议,使用 Apache qpid 作为客户端来消费来自 act 的消息(发布订阅)...
运行 artemis active mq master 时突然低于在主控制台中运行的速度
2023-09-17 09:13:56,207警告[org.apache.activemq.artemis.core.server] AMQ222149:发送消息参考[19330395685]:RELIABLE:CoreMessage [messageID = 19330395685,durable = true,userID = 02c09067-552...
不稳定的 javax.jms.JMSException:同行已处置
我在使用 Java JMS 时遇到了不稳定的问题。 暂时工作正常,但会不规律地抛出以下异常并中断执行。 重要的是要注意,这种情况发生时不会停止...
我正在尝试使用 activemq 中的队列将虚拟主题中的消息出队。我尝试发送一些消息,它显示在“消息排队”下的主题中,但无法合并...
C# 中的 ActiveMQ PooledConnectionFactory (Apache.NMS)
我正在研究在C#.Net中使用PooledConnectionFactory的方法(我们正在使用Apache.NMS)。到目前为止我找到的文档,例如: http://activemq.apache.org/spring-support.html 和 http://
我想知道RabbitMQ中何时创建单个队列以及何时创建多个队列是否有规则?或者由生产者决定是否将消息发送到单个队列或多个队列,并且
Quarkus 与 JPA / Hibernate Session 导致 JMS 线程中出现 ContextNotActiveException
我尝试从线程使用Panache存储库,该存储库不是由Quarkus“管理”的(因为我们使用ActiveMQ 5 JmsListeners,其中javax.jms.MessageConsumer在其自己的线程池中运行......
我是 Apache ActiveMQ 的新手,在 ActiveMQ 中发送和存储大量大消息(最大的消息约为 100mb)时遇到一些问题。消息是持久的,所以据我所知它们存储在...
Apache activemq-broker jar 的替代方案是什么,它支持 Jakarta(如 JDK 17 和 Spring 6)?
我有一个基于 Spring 5 的应用程序,它使用 Apache activemq 客户端和代理库。我们现在正在迁移到 Spring 6,它需要 JDK 17 指定的 Jakarta 命名空间。B...
类型不匹配:无法从ActiveMQQueue转换为Queue
我按照本教程让我的主应用程序作为侦听消息的服务器运行,并作为支持应用程序/客户端使用 ActiveMQ 远程服务器发送消息。 我在
如何使用 Apache.NMS.ActiveMQ 客户端在 C# 中向多个队列发送消息? IE。类似于 RabbitMQ fanout:当发布者发送消息并由多个队列接收时。我使用 ActiveMQ &...
jersey Rest Web 服务与 Activemq 中间件集成
我有一个使用 JAX-RS 和 jersey 开发的 Restful 服务 API。我已经在 TOMCAT 7 中部署了相同的内容。现在我想实现 Activemq,以便将所有请求保留在队列中并处理
如何通过 ssl 而不是用户/密码连接到 ActiveMQ Artemis 代理?
我通过 jmx 连接到代理。我使用用户/密码进行连接。现在您需要通过 ssl(证书)进行连接。如何以及在哪里附加证书以便通过 ssl 进行连接?我知道我不需要...
如何在Wildfly中禁用ResourceAdapter注释
我有一个 java 代码,其中包含我在 Wildfly 中部署的 EAR 中的 @ResourceAdapter 注释: @MessageDriven(activationConfig = { @ActivationConfigProperty(propertyName = "目的地...