xxxxxxxxxx
62
let mqttClient;
let hostname = "yonetwork1.cloud.shiftr.io"; //shiftr broker URL
let port = 443; //always use 443 for browser-based (HTTPS) connections
let username = "yonetwork1"; //the name of your broker
let password = "ITPCamp2k22"; //the password/"token secret" you set
let clientID = ":)"; //displayed in shiftr interface
//function triggered by "connect to MQTT broker" button
function MQTTConnect() {
mqttClient = new Paho.MQTT.Client(
hostname, port, clientID
);
mqttClient.connect({
userName: username,
password: password,
useSSL: true, //required for browser-based MQTT clients
onSuccess: function() {
mqttClient.subscribe("stuff/moreStuff");
mqttClient.onMessageArrived = function(msg){
console.log(msg.destinationName);
}
}
});
onSuccess: function() {
mqttClient.onMessageArrived = function() {
};
}
onFailure: function() {
}
}
//function triggered by "send an MQTT message" button
function sendMQTTmessage() {
let topic = "just shower thoughts";
let payload = "why do we get on a bus but in a car"; //actual message contents
let MQTTmessage = new Paho.MQTT.Message(payload);
MQTTmessage.destinationName = topic;
//if retained, message is still received if client subscribes after message is sent
MQTTmessage.retained = false;
//publish the message!
mqttClient.send(MQTTmessage);
}
function MQTTsubscribe() {
let topic = "";
mqttClient.subscribe(topic);
}