activemq-artemis相关内容

ApacheActiveMQ Artemis持久订阅TTL

我希望配置持久主题,但我希望配置Apache ActiveMQ Artemis为该主题的非活动持久订阅者保留消息的时间。 例如,类似“为非活动的持久订阅者保存持久消息最多30秒”。如果订阅者在30秒内未变为活动状态,则当他们处于活动状态时,该消息将不再可用。 这是可以做到的吗?如果不是,Artemis或JMS是否提供替代方法来实现这一点或类似的事情。 推荐答案 Active ..
发布时间:2022-08-04 18:35:20 其他开发

客户端工具MQTT.fx上定义的主题未使用ActiveMQ Artemis消息

我的用例保证使用发布-订阅模型,因此我使用在我的Spring Boot客户端中定义的主题。我已经使用工具MQTT.fx和两个Spring Boot客户端进行了测试。两个Spring Boot客户端能够相互通信,但MQTT.fx客户端只连接到代理,不生成或使用消息。两个Spring Boot客户端都连接到端口61616,而MQTT.fx客户端连接到端口1883。 对于我的项目,我需要让MQTT ..
发布时间:2022-07-03 14:40:18 Java开发

Apache MQ Artemis-MQTT保留消息对于连接到群集中其他节点的客户端不可用

我有4个ActiveMQ Artemis 2.10.1实例在群集中运行。客户端(A)连接到其中一个节点并发布MQTT消息,QoS=0且Retention=true。当新的MQTT客户端(B)连接到集群中的另一个节点并订阅该主题时,之前发送的消息为未收到。当客户端A发布下一条消息时,客户端B将收到该消息。 客户端B连接到群集中的另一个节点时,A发送的保留消息未被客户端B接收,这是Artemis ..
发布时间:2022-03-28 17:12:21 其他开发

ActiveMQ messageId 无法停止复制

我正在使用 ActiveMQ 进行消息传递,并且有一个要求,如果消息是重复的,那么它应该由 AMQ 自动处理.为此,我生成唯一的消息密钥并设置为 messageproccessor.以下是代码: jmsTemplate.convertAndSend(dataQueue, event, messagePostProccessor -> {LocalDateTime dt = LocalDateTi ..
发布时间:2021-10-26 16:32:15 其他开发

在 ActiveMQ Artemis 中使用通配符队列时不消耗消息

如果我在 ActiveMQ Artemis test.A 和通配符队列 test.# 上创建队列,那么我可以向 test.A 发送消息> 并且它也将被传送到 test.#.但是,当我使用来自 test.# 的消息时,我惊讶地发现该消息仍然存在于 test.A 如何更改我的代码或配置以获得预期的行为? 示例代码: import org.apache.activemq.artemis.a ..
发布时间:2021-09-24 20:46:03 Java开发

如何将 WildFly 10.1.0Final Apache Artemis 1.1.0 更新到 Apache Artemis 1.3

我已经安装了 WildFly 10.1.0.Final 我在 Javascript 中创建了一个 Stomp over Websocket 客户端以直接连接到 Artemis 中的主题. 我订阅了两个客户端,但是当我关闭或取消订阅这两个客户端之一时,其他客户端会发现收到消息. 我发现了一个邮件列表,其中描述了同样的问题. http://activemq.2283324.n4.na ..
发布时间:2021-08-30 19:30:13 其他开发

消费客户端关闭后,ActiveMQ Artemis 队列被删除

我是 JMS 和 ActiveMQ Artemis 的新手,我遇到了以下问题.我通常将来自应用程序生产者的消息放入 requests 队列中: 从其他应用程序消费者那里之后,我尝试使用该消息.这样做没有问题. 但是当我关闭应用程序使用者时,request 队列被无故删除. 我的应用程序使用者是使用 Spring Boot 构建的,如下所示: @SpringBootApplica ..
发布时间:2021-08-20 20:47:47 Java开发

使用自定义 JAAS 访问 Jolokia

在 ActiveMQ Artemis 中,当我在自定义 JAAS 登录模块中使用 requisite 或 required 标志时,我无法登录到 Artemis 管理控制台(Jolokia,端口 8163).我在对移动设备进行身份验证的自定义 JAAS 登录模块中有特殊的业务逻辑.但同时我希望有一个管理员用户可以使用一些用户名/密码甚至没有密码登录到 Artemis 管理控制台.为了在 Artem ..
发布时间:2021-07-17 20:45:24 其他开发

Apache ActiveMQ Artemis 集群中的消息顺序

我正在尝试在 Apache Artemis 集群中实现消息排序.连接到集群的生产者/消费者实现高可用性.因此,在某一时刻,同一应用程序的两个实例将连接到主题或队列.到目前为止,我可以找到以下两种方法可以用于在 Red Hat AMQ/Artemis 集群中实现排序: 消息组(仅当集群中的每个节点有一个消费者时才可靠) 独占队列(消息顺序仅保留在单个节点上). 我完全理解使用集群和期望 ..
发布时间:2021-07-05 19:35:28 其他开发

AMQ214013:无法解码数据包:java.lang.IllegalArgumentException:AMQ119032:无效类型:1

我在 widlfly 上的 activeMQ 工作正常,而且从星期一开始我这周开始出现这个异常并且非常频繁. 起初我进入堆栈跟踪并通过代码 grep 查看代码,该代码抛出此异常,在我看来,问题可能与消息的大小有关.我停止了在队列中输入消息的过程.并打开了我的野蝇.队列中没有数据,但我仍然收到此异常. 我从数据目录中删除了 activeMQ 数据目录和 tx-object-store.我 ..
发布时间:2021-06-07 19:23:30 其他开发

CordaFTP可能由于Artemis无法传输大文件

我正在使用此演示. CordaFTPdemo 可以进行动手操作.但是,我发现大文件无法传输,并且出现了异常 java.lang.IllegalArgumentException:Artemis消息中缺少经过验证的用户从ServerSessionPacketHandler中的slowPacketHandler调用时,ServerSession不会设置经过验证的用户. JIRA在这里问题是当我 ..
发布时间:2021-04-24 20:08:41 其他开发

使用AMQ 7.0.1的AppDynamics监视

我正在使用AppDynamics的ActiveMQ扩展.很好开始.使用JMXRemote(在artemis.profile中启用)可以.但是,我想要从本地主机.默认情况下,AMQ的localhost启用了JMX. AMQ管理控制台在内部使用jmx,并且无需启用JMXRemote即可工作. jolokia在内部使用哪些服务URL通过本地主机上的JMX进行连接?我尝试使用以下URL: servi ..
发布时间:2021-02-12 19:17:45 其他开发

如何在Artemis中获得队列大小(深度)

使用Java客户端API,如何在远程ActiveMQ Artemis 2.4.0 代理中获取队列大小? 解决方案 诸如统计信息之类的功能属于管理API.可以通过消息传递API通过HTTP(jolokia),JMX或JMX对其进行访问. 官方文档中有一个示例足以阅读它. 为了方便起见,我会在这里背诵. ClientSession session = ... ClientReque ..
发布时间:2021-02-12 19:13:45 其他开发