谢谢K
是否需要Spring Boot ActiveMQ使用者连接池来配置?我在spring boot应用程序中只有一个消费者(作为一个微服务),生产者在另一个应用程序中。我对以下内容并不感到困惑:(摘自http://activemq.apache.org/spring-support.html) 注意:虽然PooledConnectionFactory确实允许创建活动使用者的集合,但它并不“聚集”使用者
根据这个页面,我已经使用代理插件在我们的Artemis实例上启用了消息传递日志。为了通过在publisher->artemis server->subscriber之间映射端到端的消息传递和接收时间来绘制一些分析,我试图查看记录到artemis日志文件(即特定的消息ID)中的消息内容是否可以被我们拥有的发布和订阅的.NET应用程序访问。下面是来自Artemis.log文件的日志,其中包含指示各种事
我们在ActiveMQ Artemis中面临一个问题。其中一个队列在达到最大内存设置-时进入分页状态。经过一段时间后,当用户处理它时,消息数量会减少很多。但直到队列为空,它才恢复分页状态。是预期的行为吗?
当接收到单个队列使用者和多个生产者时,是否有可能出现消息顺序问题?在发布消息在发布消息。连接到被配置为单个使用者的队列的客户端代码应该按照和的顺序接收消息,正确吗?有时信息的接收顺序是错误的。版本为ActiveMQ Artemis 2.17.0。尽管我提到了多个生产者,消息还是使用属性从同一线程陆续发布。 我在每个消息发布时创建并关闭生产者。在相同的JVM上,我的假设是队列中发布消息的顺序,来自同
我已经使用Eclipse微配置文件发射器在Quarkus应用程序中创建了一个ActiveMQ Artemis生成器。但是消息会立即过期,并被移到中。我不确定这种行为。请建议如何将消息保存到队列中,以便它仅在指定时间后过期。 我正在使用下面的代码。
第一,你能确认行为的改变吗?第二,有没有恢复的方法?还有一个额外的好处,如果有人知道为什么会发生这种变化,我很想理解。
我正在Windows.NET环境中使用RabbitMQ、ActiveMQ“Classic”和ActiveMQ Artemis进行一些测试。RabbitMQ和ActiveMQ“Classic”附带了一个web界面,您可以在其中看到关于代理、队列、消息等的信息,但ActiveMQ Artemis没有。我非常希望能够在web界面或至少使用一些cmd/powershell命令来监视我的ActiveMQ A
我正在设计一种机制来处理消费者没有收到的消息。
我使用的是ActiveMQ Artemis 2.10,在我的用例中,我希望避免队列中有重复的消息,所以在向队列发送消息之前,我设置了属性message.hdr_duplicate_detection_id: 但问题是,即使在此消息被消耗之后,如果我试图发送另一个具有相同hashVal值的消息,新消息也会被拒绝。即使队列中没有其他具有相同hashVal值的消息。 是否有一种方法可以将重复检测设置为仅
如果考虑到可伸缩性,让所有使用者调用一个负责管理特定队列的节点意味着所有流量都流向一个节点。 Kafka允许使用者从最近的节点获取数据,如果该节点包含leader的副本,那么ActiveMQ上有类似的内容吗?
因此,如果我理解正确的话,在检测并重新启动失败代理的环境中运行Artemis代理集群将提供与运行每个活动服务器都与备份配对的集群相同的语义(以及类似的可用性)。对吗?
ActiveMQ Artemis文档说明: 如果是,是否意味着被动模式下的代理只是路由器?
我有两个运行在不同机器上的ActiveMQ Artemis代理,组成一个简单的集群。我正在使用一个Java应用程序(非常基本)来生成和使用消息,以分析集群的行为。Java代码如下所示: 同时在处使用断点调试上述应用程序。如果我停止我的主代理,那么我会看到从代理接管,所有的消息都像预期的那样被移动到从代理。但是,此时,如果我继续使用我的应用程序,它将抛出,而不是在从代理中使用消息。当我再次启动主代理