<script type="text/javascript">
// Create a client instance
var client = new Paho.MQTT.Client("192.168.xxx.xxx", 51041, "clientId_" + parseInt(Math.random() * 100, 10));
console.log(client);
// set callback handlers
client.onConnectionLost = onConnectionLost;
client.onMessageArrived = onMessageArrived;
// connect the client
client.connect({onSuccess:onConnect});
// called when the client connects
function onConnect() {
// Once a connection has been made, make a subscription and send a message.
console.log("onConnect");
client.subscribe("all/#");
message = new Paho.MQTT.Message("Hello");
message.destinationName = "all/connect";
client.send(message);
}
// called when the client loses its connection
function onConnectionLost(responseObject) {
if (responseObject.errorCode !== 0) {
console.log("onConnectionLost:"+responseObject.errorMessage);
}
}
// called when a message arrives
function onMessageArrived(message) {
console.log("onMessageArrived:"+message.payloadString);
}
</script>
