我想拦截mqtt客户端发送给artemis代理的消息。我遵循的是"interceptor-client-mqtt“示例。我的问题是我总是得到一个错误"java.lang.ClassNotFoundException: SimpleMQTTInterceptor“。我的问题是，我应该将拦截器类放在哪里，以便代理可以找到它？我应该只放置拦截器的类，还是应该放置一个jar文件？
浏览 9提问于2017-08-09得票数 0
回答已采纳
为了拦截mqtt客户端连接，我在我的artemis代理中添加了一个mqtt拦截器： {
System.out.println("MQTT(mqttMessage instanceo
浏览 2提问于2017-08-11得票数 0
回答已采纳
有没有人可以指导我如何在ActiveMQ Artemis broker上截获MQTT消息？我按照手册中的建议进行了尝试，但是MQTT消息没有被拦截。但是，消息的发布和订阅工作得很好。拦截器类： @Override r
浏览 0提问于2016-06-29得票数 1
我正在创建一个简单的Thorntail服务，它将向远程ActiveMQ队列写入一条文本消息，并让MDB使用该消息。为了测试这一点，我让ActiveMQ在本地Docker容器中运行。我的docker-compose.yml文件的相关部分如下所示： image: webcenter/activemq - 1883:1883 - 8161:8161 - 61614:61614 environment:
浏览 3提问于2019-05-17得票数 2
当我在一个AMQ Artemis队列中收到一个大消息(100KiB+)，并试图将这个消息路由到另一个AMQ，并且这个消息具有_AMQ_LARGE_SIZE属性时，我得到了以下错误： 14:38:56.250Caused by: javax.jms.JMSRuntimeException: Invalid address QUEUE.TEST
at org.apache.activemq.artemis.jms.client.ActiveMQDestination.fromAddress(ActiveMQDestination.java:119
浏览 28提问于2019-06-06得票数 0
回答已采纳
穆斯基托MQTT代理提供了一个功能，将两个MQTT代理连接起来，用于发布和订阅消息。这是描述的。当任何客户端将消息发布到ActiveMQ Artemis时，我希望根据配置的主题映射自动将这些消息发布到另一个MQTT。我想知道是通过内置到ActiveMQ Artemis的特性还是可能通过代理插件实现的。
浏览 0提问于2018-11-30得票数 1
回答已采纳
我想知道是否可以在客户端配置消息重传。我已经阅读了ActiveMQ的Artemis，并且没有发现任何关于这个特性的信息。因此，我得出结论，没有机会在客户端配置消息重传。
浏览 0提问于2021-11-20得票数 0
回答已采纳
我们偶尔会遇到阻断的Artemis (v2.19.1) TLS受体。阻止意味着客户端可以建立TCP连接，但不会发生进一步的数据交换。TLS握手从来没有开始过。Artemis日志中没有有用的信息。目前唯一的解决办法是重新启动Artemis。
受影响者仅为受体artemis-tls。受主stomp-tls和mqtt-tls继续工作，但没有任何负载。1048576;tcpReceiveBufferSize=1048576;amqpMinLargeMessageSize=102400;proto
浏览 15提问于2022-08-29得票数 0
我正在尝试设置带有嵌入式Artemis的wildfly16，并支持mqtt。这些是我的配置文件 我已经能够将消息从JMS java客户端和MQTT java客户端发布到jms-topic jms/topic/test1。我已经能够从JMS java客户端接收消息，但是不可能从任何具有paho库、MQTTBox或Jmeter的mqtt客户端Java客户端订阅主题jms/ topic /test1。
浏览 49提问于2019-04-14得票数 0
两个Spring客户机都连接到端口61616，而MQTT.fx客户机连接到端口1883。Spring客户端通信时的日志如下所示。当从Spring客户端向AMEBAA000105.device.weatherForecast发布消息由另一个Spring客户机触发时，MQTT.fx不会捕获该消息。在artemis.log文件中，MQTT.fx一直在
浏览 0提问于2021-09-29得票数 0
回答已采纳
我在两个Ubuntu 18.04虚拟机上使用Artemis 2.14和Java 14.0.2，该虚拟机有4个内核和16 GB RAM。我的制作人每秒向大约5500个不同的主题发送大约2000条消息。当我使用基于证书的授权通过客户端连接并订阅#时，MQTT.FX客户端会在一段时间后死亡，并且在web控制台中，我在#下看到一个队列，其中包含我的客户端id，该队列不会被Artemis清除。一段时间后，我的Artemis代理重新启动。
Artemis的这种行为
浏览 2提问于2020-08-12得票数 0
我已经在Linux上安装了ActiveMQ Artemis并配置了broker.xml。我使用的是证书，但ActiveMQ Artemis使用的是密钥库和信任库。如何创建它们，如何为MQTT协议启用SSL？ 下面显示了配置broker.xml <acceptor name="mqtt">tcp://0.0.0.0:1883?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=MQTT</
浏览 26提问于2020-09-07得票数 0
回答已采纳
对于试图在artemis主题中发布mqtt消息的用户，我希望将消息的大小限制在800 KB以内，为此，我已经在800/CN.15.xml中更新了地址设置。<max-size-bytes>800</max-size-bytes>这似乎不起作用，我可以通过MQTT客户端发布1MB
浏览 1提问于2020-06-15得票数 0
回答已采纳
我在Spring客户端上使用JMS通过SSL连接到ActiveMQ Artemis代理。无论信任存储中的证书是否有效，即使使用无效的凭据，客户端都能够连接。如何确保代理根据配置的参数过滤客户端？1048576;tcpReceiveBufferSize=1048576;amqpMinLargeMessageSize=102400;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT-- MQTT Acceptor -->
<acceptor n
浏览 13提问于2021-10-01得票数 1
回答已采纳
为了利用Artemis，需要重构C#代码吗？如何使用.NET在Artemis中获得代理/队列度量？
浏览 4提问于2022-06-03得票数 0
当客户端从多个VM连接到代理时，我注意到代理(主)日志更频繁地显示以下消息。下面的消息一直在填充artemis.log。有投入吗？(PacketDecoder.java:481) [artemis-core-client-2.13.0.jar:2.13.0]
at org.apache.activemq
浏览 16提问于2020-07-26得票数 2
2回答
我使用Apache Artemis作为我的mqtt代理。我有一个Artemis集群，它是以主从方式配置的。当主服务器发生故障时，备份服务器接管，客户端必须连接到从服务器。主备IP不同。
浏览 13提问于2016-08-19得票数 1
回答已采纳
我正在从事从Artemis5.0到ActiveMQ ActiveMQ的迁移工作。我看到消息Id格式已更改。5.0使用客户端Id作为前缀，而Artemis似乎使用一种序列。 有没有办法控制消息id？
浏览 43提问于2021-06-17得票数 0
回答已采纳
我使用，它使用Eclipse客户端向Artemis服务器发送MQTT消息。在我的应用程序上运行性能测试时，我会收到一个‘太多发布正在进行’的错误。
浏览 0提问于2018-02-02得票数 4
回答已采纳
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
腾讯云开发者
