activemq-artemis相关内容
我希望配置持久主题,但我希望配置Apache ActiveMQ Artemis为该主题的非活动持久订阅者保留消息的时间。 例如,类似“为非活动的持久订阅者保存持久消息最多30秒”。如果订阅者在30秒内未变为活动状态,则当他们处于活动状态时,该消息将不再可用。 这是可以做到的吗?如果不是,Artemis或JMS是否提供替代方法来实现这一点或类似的事情。 推荐答案 Active
..
我的用例保证使用发布-订阅模型,因此我使用在我的Spring Boot客户端中定义的主题。我已经使用工具MQTT.fx和两个Spring Boot客户端进行了测试。两个Spring Boot客户端能够相互通信,但MQTT.fx客户端只连接到代理,不生成或使用消息。两个Spring Boot客户端都连接到端口61616,而MQTT.fx客户端连接到端口1883。 对于我的项目,我需要让MQTT
..
我有4个ActiveMQ Artemis 2.10.1实例在群集中运行。客户端(A)连接到其中一个节点并发布MQTT消息,QoS=0且Retention=true。当新的MQTT客户端(B)连接到集群中的另一个节点并订阅该主题时,之前发送的消息为未收到。当客户端A发布下一条消息时,客户端B将收到该消息。 客户端B连接到群集中的另一个节点时,A发送的保留消息未被客户端B接收,这是Artemis
..
我使用的是 Apache Artemis V2.12.0,在两个虚拟机中启动了两个代理实例 broker.xml (myhost1) [myhost2 的 broker.xml 类似,只是我使用的端口是 61616] tcp://0.0.0.0:61617?amqpIdleTimeout=0;tcpSen
..
Broker.xml (host1) 和 host2 只是端口号更改为 61616 和 slave 作为配置.参考 Apache Artemis 客户端故障转移发现 tcp://0.0.0.0:61617?amqpIdleTimeout=0;tcpSendBufferSize=1048576;tcpReceiv
..
我正在使用 ActiveMQ 进行消息传递,并且有一个要求,如果消息是重复的,那么它应该由 AMQ 自动处理.为此,我生成唯一的消息密钥并设置为 messageproccessor.以下是代码: jmsTemplate.convertAndSend(dataQueue, event, messagePostProccessor -> {LocalDateTime dt = LocalDateTi
..
看来远程客户端的netty-connector不开心!现在,我使用标准 616161 端口在本地机器上运行.我按照 https://docs.jboss.org/author/display/WFLY/Connect+a+pooled-connection-factory+to+a+Remote+Artemis+Server 这里是错误: 12:18:50,707 INFO [org.ap
..
如果我在 ActiveMQ Artemis test.A 和通配符队列 test.# 上创建队列,那么我可以向 test.A 发送消息> 并且它也将被传送到 test.#.但是,当我使用来自 test.# 的消息时,我惊讶地发现该消息仍然存在于 test.A 如何更改我的代码或配置以获得预期的行为? 示例代码: import org.apache.activemq.artemis.a
..
我正在使用 Spring WebSockets 实现一个 WebSockets 应用程序. 作为STOMP经纪人,我想使用Wildfly的Artemis(Active MQ). 我在standalone-full.xml中做了如下配置: 添加以下接受器:
..
我正在尝试在 Oracle 12.x 和 Redhat ActiveMQ Artemis 7.4 之间建立桥梁.这是设置桥接器所做的工作: 将 artemis-jms-client-all-2.9.0.redhat-00005.jar 设置为 WL 类路径 将以下属性设置为 WL 类路径: java.naming.factory.initial=org.apache.activemq
..
我已经安装了 WildFly 10.1.0.Final 我在 Javascript 中创建了一个 Stomp over Websocket 客户端以直接连接到 Artemis 中的主题. 我订阅了两个客户端,但是当我关闭或取消订阅这两个客户端之一时,其他客户端会发现收到消息. 我发现了一个邮件列表,其中描述了同样的问题. http://activemq.2283324.n4.na
..
我是 JMS 和 ActiveMQ Artemis 的新手,我遇到了以下问题.我通常将来自应用程序生产者的消息放入 requests 队列中: 从其他应用程序消费者那里之后,我尝试使用该消息.这样做没有问题. 但是当我关闭应用程序使用者时,request 队列被无故删除. 我的应用程序使用者是使用 Spring Boot 构建的,如下所示: @SpringBootApplica
..
在 ActiveMQ Artemis 中,当我在自定义 JAAS 登录模块中使用 requisite 或 required 标志时,我无法登录到 Artemis 管理控制台(Jolokia,端口 8163).我在对移动设备进行身份验证的自定义 JAAS 登录模块中有特殊的业务逻辑.但同时我希望有一个管理员用户可以使用一些用户名/密码甚至没有密码登录到 Artemis 管理控制台.为了在 Artem
..
我正在尝试在 Apache Artemis 集群中实现消息排序.连接到集群的生产者/消费者实现高可用性.因此,在某一时刻,同一应用程序的两个实例将连接到主题或队列.到目前为止,我可以找到以下两种方法可以用于在 Red Hat AMQ/Artemis 集群中实现排序: 消息组(仅当集群中的每个节点有一个消费者时才可靠) 独占队列(消息顺序仅保留在单个节点上). 我完全理解使用集群和期望
..
我在 widlfly 上的 activeMQ 工作正常,而且从星期一开始我这周开始出现这个异常并且非常频繁. 起初我进入堆栈跟踪并通过代码 grep 查看代码,该代码抛出此异常,在我看来,问题可能与消息的大小有关.我停止了在队列中输入消息的过程.并打开了我的野蝇.队列中没有数据,但我仍然收到此异常. 我从数据目录中删除了 activeMQ 数据目录和 tx-object-store.我
..
我正在使用此演示. CordaFTPdemo 可以进行动手操作.但是,我发现大文件无法传输,并且出现了异常 java.lang.IllegalArgumentException:Artemis消息中缺少经过验证的用户从ServerSessionPacketHandler中的slowPacketHandler调用时,ServerSession不会设置经过验证的用户. JIRA在这里问题是当我
..
Broker.xml(主机1)和主机2只是端口号更改为61616,而从机则作为配置.参考 Apache Artemis客户端故障转移发现
..
我正在使用AppDynamics的ActiveMQ扩展.很好开始.使用JMXRemote(在artemis.profile中启用)可以.但是,我想要从本地主机.默认情况下,AMQ的localhost启用了JMX. AMQ管理控制台在内部使用jmx,并且无需启用JMXRemote即可工作. jolokia在内部使用哪些服务URL通过本地主机上的JMX进行连接?我尝试使用以下URL: servi
..
使用Java客户端API,如何在远程ActiveMQ Artemis 2.4.0 代理中获取队列大小? 解决方案 诸如统计信息之类的功能属于管理API.可以通过消息传递API通过HTTP(jolokia),JMX或JMX对其进行访问. 官方文档中有一个示例足以阅读它. 为了方便起见,我会在这里背诵. ClientSession session = ... ClientReque
..
是否可以获得(或构建)与Java 1.7兼容的artemis-jms-client-all-2.x.0.jar的等效项? 我需要它,因为Weblogic SOA 10.x不支持Java 1.8,并且我想将其连接到ActiveMQ Artemis. 解决方案 ActiveMQ Artemis JMS客户端(及其许多依赖项)使用Java 1.8中的语言功能,因此没有与Java 1.7兼容
..