我想配置一个持久主题,但我想配置Apache ActiveMQ Artemis将为该主题的非活动持久订阅服务器保留消息的时间。 例如,类似“为非活动的持久订阅服务器保存持久消息长达30秒”的内容。如果订阅服务器在30秒内没有变为活动状态,则当订阅服务器变为活动状态时,消息将不再可用。
依赖关系:
之后,我尝试从其他应用程序使用者那里使用该消息。这没有问题。 我的应用程序使用者是用Spring Boot构建的,如下所示: 顺便说一句,最初的队列是在应用程序生成器将消息发送到ActiveMQ Artemis时创建的,并使用完成,如下所示:
我配置了两台机器,每台机器都有10个使用者,它们侦听在第三台机器上运行的相同activemq队列。但只有一台机器的使用者正在读取队列中的消息,而另一台机器则处于空闲状态 我希望activemq web控制台上有20个消费者,但只能看到10个。 问题是什么?在应用程序端或activemq端有任何配置更改吗? 我正在使用spring-jms(org.springframework.jms.listen
我有两个ActiveMQ Artemis实例,只需使用命令/.Artemis创建Artemis/server1和 /.Artemis创建Artemis/server2 以下是服务器1的broker.xml: 下面是服务器2的broker.xml: 同样在server2中,Bootstrap.xml中的更改更改了web绑定端口 我正在用StaticClusteredQueueExample和这个示例
如果ActiveMQ Artemis配置了>0,并且JMS侦听器使用或,那么代理将按预期重新传递消息。但是,如果生产者在重新传递期间将消息推送到队列中,那么接收者将获得无序的消息。 例如: 队列:1->消息1按预期重新传递 重新交付阶段的推送 当为时,一切都没问题,但是用户端的重新交付频率太高了。我的期望是,在未确认的消息从队列中清除或确认之前,应该停止向使用者的每一次传递。我们正在使用一个队列来
我不知道如何让Wildfly12中的消息传递子系统在原始节点失败时将队列消息重新传递到不同的节点。我需要一种方法,当第一个尝试的节点没有足够快地确认/提交时,将消息定向到不同的节点。 我有一个3节点的Wildfly12集群,只有一个队列(TestQueue)。我使用单个bean部署应用程序,该bean获取JMS连接并创建与队列中的使用者的会话;下面是构造函数: 连接工厂和目的地被注入到其他地方:
我试图将messaging-activemq子系统配置为使用https而不是http(以完全消除http的使用)。 在Wildfly配置文件messaging-activemq子系统中,我已经更新了http-connector、http-connector-aphults、http-acceptor-aphulth和http-acceptor-aphulth以使用https。Wildfly服务器启
谁能解释一下ActiveMQ重新交付策略实际上是如何工作的?它是在客户端还是在服务器端工作? 假设我有一个重新传递策略,每次尝试之间间隔30分钟,重新传递消息长达10分钟,那么失败的消息到底在哪里? 假设消息现在失败了,30分钟后重新发送,那么消息在哪里? http://activemq.apache.org/redelivery-policy.html http://activemq.apach
这个时间是可配置的吗? 谢了!
我试图在Apache Artemis集群中实现消息排序。连接到集群的生产者/消费者实现了高可用性。因此,在某个时间点,将有两个相同应用程序的实例连接到主题或队列。到目前为止,我可以发现以下两种方法可用于在Red Hat AMQ/Artemis集群中实现排序: 消息组(根据文档,只有当集群中每个节点有一个使用者时才是可靠的) 独占队列(仅在单个节点上保留消息顺序)。 我完全理解使用集群和期望消息排序
在ActiveMQ5.x中,当使用kahadb进行持久化时,所有文件都在一个数据库中管理。这会产生严重的后果。 我有数百个队列,每天看到数百万条消息。如果队列的使用者由于维护原因而暂时停止,队列将继续填充和清空,使用者被挂起的队列将看到消息累积。但在光盘上就不一样了。Kahadb确实会标记删除(消耗)的消息,但如果数据库中保留了更多的消息,则无法释放该位置。在挂起队列中积累的就是这种情况。磁盘空间
我正在尝试实现ActiveMQ Artemis。Artemis是ActiveMQ的一部分吗? 我试图使周期性任务延迟和调度消息传递ActiveMQ,但唯一有效的是延迟调度消息。文档中有关于核心API的说明: null
我是ActiveMQ Artemis新手, 我试图理解ActiveMQ Artemis中的对称集群。 这里是我试图理解的例子。 我正在从集群节点获取正在使用的主题消息和队列消息列表,如何获取关于节点的信息意味着哪个节点正在返回这些信息(队列消息/主题消息)