使用 MQTT 主题的 ActiveMQ Spring 集成

Question

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

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

但我收到一条错误消息

错误：消息不是预期的 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 consumer中，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);
}