用Wildlfy 11嵌入式Apache Artemis接收MQTT消息

Question

当前状态：

>

我将MQTT协议支持添加到Wildfly embedded Apache Artemis（添加了“Missing”文件夹和Artemis-mqtt-protocol-.jar，并在module.xml中启用了该协议）

我正在为MTQQ使用完整的独立配置和添加的acceptor：

<subsystem xmlns="urn:jboss:domain:messaging-activemq:2.0">
  <server name="default">
        <remote-acceptor name="mqtt-acceptor" socket-binding="mqtt">
          <param name="protocols" value="MQTT"/>
        </remote-acceptor>

<jms-topic name="testEndpoint" entries="java:/jms/testEndpoint"/>

AMQ221020:协议[MQTT]在127.0.0.1:1883启动接受器

AMQ221007:服务器现在是活动的AMQ221001:Apache ActiveMQ Artemis Message Broker版本1.5.5.jbossorg-008

AMQ221003:部署队列jms.queue.dlq

AMQ221003:部署队列jms.queue.expiryqueue

WFLYMSGAMQ0002:将消息传递对象绑定到jndi名称java：jboss/exported/jms/remoteConnectionFactory

AMQ221052:部署主题jms.topic.TestEndPoint

    @MessageDriven(
            activationConfig = { @ActivationConfigProperty(propertyName = "destination", 
                                                           propertyValue = "testEndpoint"), 
                                 @ActivationConfigProperty(propertyName = "destinationType", 
                                                           propertyValue = "javax.jms.Topic")
            },
            mappedName = "testEndpoint")
    public class TestEndpoint implements MessageListener {

        private static final Logger logger = Logger.getLogger(TestEndpoint.class.getName());

        public void onMessage(Message message) {
            try {
                logger.debug("message: " + message.getClass().getName());
            } catch (Exception e) {
                logger.debug("exception: " + e.getMessage());
            }
        }

    }

Answer 1

日志是这样说的：

AMQ221052:部署主题jms.topic.TestEndPoint

它还说：