Zastanawiam się nad zbudowaniem klienta Java AWS IoTz Apache Camel (przy użyciu camel-mqtt) + Spring Boot. Brzmi dla mnie jak dobre dopasowanie, ale nie mogę znaleźć żadnych przykładów. Czy jest jakaś wada, której nie widzę? Byłbym zainteresowany, aby zobaczyć wszelkie wskazówki.
Odpowiedzi:
0 dla odpowiedzi № 1Mam to działa z poniższą konfiguracją. sslContext bean posiada certyfikat / bezpieczeństwo:
@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());
}
};
}