ActiveMQ Spring 使用 MQTT 主题集成

Question

我是 activemq 的新手。我在 activeMQ 中创建一个主题。并通过 mqtt

发布数据

mosquitto_pub   -d -t testTopic -m "test message"

但是我收到一条错误消息

ERROR : Message is not of expected type TextMessage.

这是我的代码

    public void onMessage(Message message) {
     if (message instanceof TextMessage) {


      }
      else
      {

        logger.error("Message is not of expected type TextMessage.");
      }
}

实际问题是什么？ .但我成功地通过 http 将数据发送到同一主题。

有什么想法...???

Answer 1

在ActiveMQ Spring消费者中，http消息是文本消息类型，mqtt消息是BytesMessage类型。因为我添加了一些代码

if (message instanceof BytesMessage) {
                BytesMessage bm = (BytesMessage) message;
                byte data[];
                data = new byte[(int) bm.getBodyLength()];
                bm.readBytes(data);
                msgText = new String(data);
                System.out.println("Message String = "+msgText);
}

ActiveMQ Spring 使用 MQTT 主题集成

ActiveMQ Spring Integration using MQTT topic

java

activemq

mqtt

spring-jms