awsmqtt.orig.js

var AWSMqtt = require('aws-mqtt-client').AWSMqtt;

//Create an IAM role and asign predefined AWSIoTDataAccess policy

const mqttClient = new AWSMqtt({
      accessKeyId: '',
      secretAccessKey: '',
      sessionToken: '',
      endpointAddress: '',
      region: 'eu-west-1'
});


mqttClient.on('connect', () => {
	mqttClient.subscribe('test-topic');
	console.log('connected to iot mqtt websocket');
});
mqttClient.on('message', (topic, message) => {
	console.log(message.toString());
});

//mqttClient.publish(MQTT_TOPIC, message);