Run MQTT client
| 17 | |
| 18 | // Run MQTT client |
| 19 | void startMqttClient() |
| 20 | { |
| 21 | mqtt.setSslInitHandler([](Ssl::Session& session) { |
| 22 | session.options.verifyLater = true; |
| 23 | session.keyCert.assign(privateKeyData, certificateData); |
| 24 | }); |
| 25 | |
| 26 | Url url; |
| 27 | url.Scheme = URI_SCHEME_MQTT_SECURE; |
| 28 | url.Host = awsEndpoint; |
| 29 | mqtt.connect(url, F("Basic_AWS")); |
| 30 | |
| 31 | // Assign a disconnect callback function |
| 32 | // mqtt.setCompleteDelegate(checkMQTTDisconnect); |
| 33 | mqtt.subscribe(F("thing/fish/test")); |
| 34 | } |
| 35 | |
| 36 | // Publish our message |
| 37 | void publishMessage() |
no test coverage detected