spring-boot - Camle MQTT 未能收到已发布的主题

Question

我正在使用spring boot毁掉骆驼我有两个路由一个生产者和另一个消费者当我从RabbitMQ管理发送消息时我在消费者类中收到消息而当我运行计时器路由时我失败了下面是我的代码，有什么建议吗？

消费类：

@Component
public class CheeseRouter extends RouteBuilder {

   @Override
   public void configure() throws Exception {
      from("mqtt:cheese?subscribeTopicName=cheese")
      .routeId("rout_cheese") .log("[cheese]- ${body}").to("log:CheeseRouter-log");
   }

}

和生产者类：

@Component
public class TestRout extends RouteBuilder {
@Override
public void configure() throws Exception {
    from("timer:first-timer?period=1000")
    .routeId("rout_restful-service")
    .log("${body}")
    .to("mqtt:cheese?byDefaultRetain=true&qualityOfService=exactlyOnce&publishTopicName=cheese");
}

}

标签： spring-bootmqttspring-camelapache-camel-mail