Клиент AWS IoT MQTT с Apache camel-mqtt

Question

Я изучаю возможность создания Java-клиента AWS IoT с помощью Apache Camel (используя camel-mqtt) + Spring Boot. Это звучит как хороший матч для меня, но не смог найти никаких примеров. Есть ли какой-то недостаток, который я не вижу? Было бы интересно увидеть любые указатели.

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


            }
        };
    }