function startConnect(){
clientID = "clientID - "+parseInt(Math.random() * 100);
host = document.getElementById("host").value;
port = document.getElementById("port").value;
userId = document.getElementById("username").value;
passwordId = document.getElementById("password").value;
document.getElementById("messages").innerHTML += " Connecting to " + host + "on port " +port+"
";
document.getElementById("messages").innerHTML += " Using the client Id " + clientID +"
";
client = new Paho.MQTT.Client(host,Number(port),clientID);
client.onConnectionLost = onConnectionLost;
client.onMessageArrived = onMessageArrived;
client.connect({
onSuccess: onConnect
// userName: userId,
// passwordId: passwordId
});
}
function onConnect(){
topic = document.getElementById("topic_s").value;
document.getElementById("messages").innerHTML += " Subscribing to topic "+topic + "
";
client.subscribe(topic);
}
function onConnectionLost(responseObject){
document.getElementById("messages").innerHTML += " ERROR: Connection is lost.
";
if(responseObject !=0){
document.getElementById("messages").innerHTML += " ERROR:"+ responseObject.errorMessage +"
";
}
}
function onMessageArrived(message){
console.log("OnMessageArrived: "+message.payloadString);
document.getElementById("messages").innerHTML += " Topic:"+message.destinationName+"| Message : "+message.payloadString + "
";
}
function startDisconnect(){
client.disconnect();
document.getElementById("messages").innerHTML += " Disconnected.
";
}
function publishMessage(){
msg = document.getElementById("Message").value;
topic = document.getElementById("topic_p").value;
Message = new Paho.MQTT.Message(msg);
Message.destinationName = topic;
client.send(Message);
document.getElementById("messages").innerHTML += " Message to topic "+topic+" is sent
";
}