Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- function connectToAwsIot() {
- var options = {
- host: awsIotConfig.endpoint,
- port: 8883,
- protocol: 'mqtt',
- cert: atob(awsIotConfig.clientCertificate),
- key: atob(awsIotConfig.privateKey),
- ca: atob(awsIotConfig.caCertificate)
- }
- console.log('Connecting to AWS IoT...');
- require('tls').connect(options, function (res) {
- console.log('TLS handshake successful');
- mqtt.connect(res);
- });
- mqtt.on('connect', function () {
- console.log('MQTT connection successful');
- digitalWrite(pinLedGreen, false);
- console.log('Subscribing to ' + awsIotConfig.responseTopic);
- mqtt.subscribe(awsIotConfig.responseTopic);
- setPinModes();
- setupWatches();
- });
- mqtt.on('publish', function (pub) {
- console.log('Received message on ' + pub.topic + ': ' + pub.message);
- });
- mqtt.on('disconnected', function () {
- digitalWrite("B13", true);
- console.log('Disconnected from AWS IoT');
- });
- mqtt.on('error', function (err) {
- console.log('Error during AWS IoT connection: ' + err);
- });
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement