From bcf3120d437da01fda78397a345bf805b008eb7a Mon Sep 17 00:00:00 2001
From: Trygve Laugstøl <trygvis@inamo.no>
Date: Sun, 6 Sep 2015 21:34:13 +0200
Subject: wip

---
 src/beer-duke.js | 31 +++++++++++++++++++++++++++++++
 1 file changed, 31 insertions(+)
 create mode 100644 src/beer-duke.js

(limited to 'src/beer-duke.js')

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);
-- 
cgit v1.2.3