Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- function MQTTConnect(){
- console.log("connecting to"+ host);
- mqtt = new Paho.MQTT.Client(host,deviceId);
- var options = {
- timeout : 30,
- userName:deviceId,
- password:oAuthToken,
- onSuccess:onConnect,
- onFailure:onFailure,
- };
- mqtt.onMessageArrived = onMsgArrived;
- mqtt.connect(options);
- }
- unction onConnect(){
- //once connected create a subscription adn send msg
- console.log("connected");
- var subscribeOptions = {
- qos: 1, // QoS
- onSuccess: onSuccessCallback,
- onFailure: onFailureCallback,
- timeout: 30
- };
- var subTopic = 'iot/push/'+deviceId;
- console.log(subTopic);
- mqtt.subscribe(subTopic,subscribeOptions);
- }
Add Comment
Please, Sign In to add comment