diff options
author | Trygve Laugstøl <trygvis@inamo.no> | 2015-09-06 21:34:13 +0200 |
---|---|---|
committer | Trygve Laugstøl <trygvis@inamo.no> | 2015-09-06 21:34:13 +0200 |
commit | bcf3120d437da01fda78397a345bf805b008eb7a (patch) | |
tree | 9f4e81ca4c8e3e5fe659cc465020b076b11c82d9 /src/beer-duke.js | |
download | beer-duke-bcf3120d437da01fda78397a345bf805b008eb7a.tar.gz beer-duke-bcf3120d437da01fda78397a345bf805b008eb7a.tar.bz2 beer-duke-bcf3120d437da01fda78397a345bf805b008eb7a.tar.xz beer-duke-bcf3120d437da01fda78397a345bf805b008eb7a.zip |
wip
Diffstat (limited to 'src/beer-duke.js')
-rw-r--r-- | src/beer-duke.js | 31 |
1 files changed, 31 insertions, 0 deletions
diff --git a/src/beer-duke.js b/src/beer-duke.js new file mode 100644 index 0000000..8178836 --- /dev/null +++ b/src/beer-duke.js @@ -0,0 +1,31 @@ +import angular from 'angular'; + +function run() { + function onConnect() { + // Once a connection has been made, make a subscription and send a message. + console.log("onConnect"); + client.subscribe("/World"); + let message = new Paho.MQTT.Message("Hello"); + message.destinationName = "/World"; + client.send(message); + } + + function onConnectionLost(responseObject) { + if (responseObject.errorCode !== 0) + console.log("onConnectionLost:" + responseObject.errorMessage); + } + + function onMessageArrived(message) { + console.log("onMessageArrived:" + message.payloadString); + client.disconnect(); + } + + //let client = new Paho.MQTT.Client("trygvis.io", 9001, "/", "clientId"); + let client = new Paho.MQTT.Client("wss://trygvis.io:9001/", "clientId"); + client.onConnectionLost = onConnectionLost; + client.onMessageArrived = onMessageArrived; + client.connect({onSuccess: onConnect}); +} + +angular.module('BeerDuke', []) + .run(run); |