使用Apache camel-mqtt的AWS IoT MQTT客戶端

Question

我正在研究使用Apache Camel（使用camel-mqtt）+ Spring Boot構建AWS IoT Java客戶端。這聽起來像是一個很好的匹配，但找不到任何例子。有什麼缺點我看不到？會有興趣看到任何指針。

Answer 1

我得到它與下面的配置工作。的SSLContext豆持有證書/安全：

@Bean 
    RouteBuilder awsIoTRoute() { 

     return new RouteBuilder() { 

      @Override 
      public void configure() throws Exception { 

       from("timer://foo?repeatCount=0&delay=5000&fixedRate=true&period=17s") 
        .setBody(simple("TEST MESSAGE")) 
        .to("mqtt:awsIoTPublisher?host=ssl://{{aws.iot.host}}:8883&publishTopicName={{aws.iot.pub.topic}}&clientId={{aws.iot.pub.clientId}}&sslContext=#sslContext") 
        .log("Sent :"+body().convertToString().toString()); 

       from("mqtt:awsIoTReciever?host=ssl://{{aws.iot.host}}:8883&subscribeTopicName={{aws.iot.sub.topic}}&clientId={{aws.iot.sub.clientId}}&sslContext=#sslContext").log("Recieved : "+body().convertToString()); 


      } 
     }; 
    }