问题标签 [activemq-artemis]

如何在不使用 jboss-client.jar 的情况下连接到 WildFly 10 嵌入式 ActiveMQ-Artemis Broker？我知道它与standalone.xml 中的接受器/连接器有关。你能举个例子吗？

我克隆了 Apache ActiveMQ Artemis 项目的 git 存储库（https://github.com/apache/activemq-artemis），然后输入

我很惊讶地看到如下日志消息

由于 egartemis-core-client包含在我一开始克隆的 git 存储库中，我预计 maven 只是从那里构建它。

这样，当我在核心客户端源中进行更改时，它们会被集成测试拾取。

相反，maven 正在从存储库下载 jar。

问题：如何配置 maven 以始终构建 git 存储库中的所有模块并仅下载“真正的”依赖项，我的意思是不在 git 存储库中的东西？

有人可以指导我如何在 ActiveMQ Artemis 代理上拦截 MQTT 消息吗？我按照手册中的建议进行了尝试，但 MQTT 消息没有被拦截。但是，消息的发布和订阅工作正常。

拦截器类：

我在 addMQTTConnector 方法中将拦截器添加到配置中

代理类的完整代码位于https://codeshare.io/snZsB

我从 github 下载了 Apache Artemis 项目。Artemis 文档提到了要在文件“broker.xml”中完成的设置。但是，我找不到该文件。我查看了位置https://github.com/apache/activemq-artemis/tree/master/artemis-server/src/main/resources/schema并且文件不存在。其他项目中有很多broker.xml文件。

有人可以告诉需要修改以运行 Artemis 代理的 broker.xml 文件的位置吗？我打算通过 IDE 运行。我已经能够运行单个实例。现在我想运行一个需要更改 broker.xml 的集群，但我找不到它的位置。谢谢。

我正在尝试使用MDB内置的 ActiveMQ Artemis 连接 Wildfly 10 服务器，以连接到运行版本 5.13.3 的独立 ActiveMQ-Server。似乎 Artemis 无法与任何受支持的 ActiveMQ 协议进行通信。

ActiveMQ 独立代理具有以下功能transportConnectors：

Wildfly MessageBean具有以下内容Annotation：

根据我选择连接的连接器，我会在 ActiveMQ-Server 上收到不同的错误消息。

连接到auto-endpoint 会产生以下消息：

错误 | 无法接受连接：java.lang.IllegalStateException：无法检测到有线格式

Wildfly 方面没有错误。

连接到Openwire-endpoint 会产生以下消息：

警告 | 传输连接到：tcp://127.0.0.1:45000 失败：java.io.IOException：未知数据类型：77

这也会在 Wildfly 方面产生错误：

17:04:23,384 错误 [org.apache.activemq.artemis.core.client] (Thread-16 (ActiveMQ-client-netty-threads-1716275972)) > AMQ214013：无法解码数据包：java.lang.IllegalArgumentException：AMQ119032 : 无效类型: 1 在 org.apache.activemq.artemis.core.protocol.core.impl.PacketDecoder.decode(PacketDecoder.java:413) 在 org.apache.activemq.artemis.core.protocol.ClientPacketDecoder.decode(ClientPacketDecoder .java:60) 在 org.apache.activemq.artemis.core.protocol.ClientPacketDecoder.decode(ClientPacketDecoder.java:39) 在 org.apache.activemq.artemis.core.protocol.core.impl.RemotingConnectionImpl.bufferReceived(RemotingConnectionImpl .java:324）在 org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl$DelegatingBufferHandler.bufferReceived(ClientSessionFactoryImpl.java:1105) 在 org.apache.activemq.artemis.core。remoting.impl.netty.ActiveMQChannelHandler.channelRead(ActiveMQChannelHandler.java:68) 在 io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:308) 在 io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:294)在 io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:265) 在 io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:308) 在 io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java :294) at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:846) at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131) at io.netty.channel.nio。NioEventLoop.processSelectedKey(NioEventLoop.java:511) 在 io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468) 在 io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382) 在 io .netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354) at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:112) at java.lang.Thread.run(Thread.java:第745章）运行（Thread.java:745）运行（Thread.java:745）

我可以继续并在所有端点上接收错误消息。结果实际上是 ActiveMQ-Artemis 以 ActiveMQ 不支持的数据格式发送。

将 ActiveMQ-Artemis 与独立的 ActiveMQ-Server 连接需要采取哪些步骤？

我正在尝试设置一个使用嵌入式 JMS 队列的简单 Spring Boot 应用程序。我在 HornetQ 上很成功，但是当我尝试转换为 Artemis 时，我在 ArtemisConnectionFactory 上遇到了失败。这是我用于 HornetQ 的代码。任何帮助将不胜感激。

我将 ActiveMQ Artemis 嵌入到 WildFly10（如它提供）中，并希望通过 Hawt.io 对其进行监控。

我做了什么：

• ActiveMQ Artemis 已配置并正在运行
• 我将 hawtio.war 放到了部署目录中。
• 我放弃了由 maven artemis-plugin 构建，名称更改为 artemis-plugin.war
• 我什至放弃了 jolokia.war

我尝试使用独立的 jar - 制作了一个插件目录并将 artemis-plugin.war 放在那里。

当我连接到 jolokia 时，我得到了 WildFly 的 CPU 使用率（以及类似的东西），我可以通过 JMX 看到队列，但仍然可以通过 Artemis 获得成功。

hawtio 无法识别插件hawtio 无法识别插件，但是它已加载：

我没有“Artemis”标签。，去http://0.0.0.0:8081/artemis-plugin显示目录：

目录：/artemis-plugin/

有任何想法吗？

我正在尝试设置 2 个支持 HA 和故障转移的 ActiveMQ Artemis 服务器。但我在文档和本示例中看到的是 Artemis 不可扩展，因为我必须在代码中为每个 Artemis 节点设置连接和会话。这意味着如果我想通过添加第三台服务器来扩展 Artemis，那么我必须在存在与该服务器的连接和会话的情况下发布新的代码版本，对吗？

这是否也意味着当故障服务器启动并再次出现在集群上时，我必须手动创建一个新连接和一个新会话？

我无法将 Artemis REST 功能集成到我的一个项目中。更准确地说，一切都很好，直到我尝试使用队列中的消息。

我正在遵循文档中提到的过程。该 API 遵循 HATEOAS 原则，这意味着您基本上是通过 api 调用来进行的，这些调用返回指向 url 的超链接，这些链接本身并不用于进行调用。

该过程包括

1. 发布消息
2. 创建一个拉取资源来消费消息
3. 实际上是通过 pull-resource 消费消息

在第 3 点之前工作正常。

调用端点会导致异常，抱怨要使用的消息类型不正确。这是堆栈跟踪：

该应用程序在 Wildfly 10 中运行，其中包括版本 1.1.0 中的 Artemis（artemis 其余版本：1.1.0）。

我试图通过请求传递我的消息的内容类型。但无论我提供什么类型，它似乎都没有效果。

在这一点上，我对这个错误一无所知。希望任何人都可以指出我正确的方向。

在此先感谢，托马斯。

我需要在 Apache artemis 中安排消息

我试图发送这个单脚框架：

但它不起作用。

我已经尝试过这些属性..也没有希望：

我不知道是否需要将代理配置为支持预定消息.. 像 activemq。但我也试过了。在 bootstrap.xml 我添加了这个选项