AWS IoT MQTT Client mit Apache camel-mqtt

Question

Ich bin dabei, einen AWS IoT Java Client mit Apache Camel (mit camel-mqtt) + Spring Boot zu erstellen. Das hört sich nach mir an, aber ich konnte keine Beispiele finden. Gibt es einen Nachteil, den ich nicht sehen kann? Wäre interessiert, irgendwelche Hinweise zu sehen.

Answer 1

Ich habe es mit der folgenden Konfiguration arbeiten. SSL-Kontext Bohne hält das Zertifikat/Sicherheit:

@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()); 


      } 
     }; 
    }