stom client improvements:

- heart beat from client and server
- show error when server down
- show error when server does not send heart beat
- show debug information

diff --git a/angularjs/stomp/src/stomp/app/example/example.controller.js b/angularjs/stomp/src/stomp/app/example/example.controller.js
index d3b06fa..56b9d14 100644 (file)
--- a/angularjs/stomp/src/stomp/app/example/example.controller.js
+++ b/angularjs/stomp/src/stomp/app/example/example.controller.js
@@ -25,7 +25,9 @@
     var client;
     var subscription;
 
-    vm.url = $location.protocol() + '://' + $location.host() + '/spring-stomp-server-full/fullportfolio';
+    vm.endpointSimple = $location.protocol() + '://' + $location.host() + '/spring-stomp-server-simple/portfolio';
+    vm.endpointFull = $location.protocol() + '://' + $location.host() + '/spring-stomp-server-full/fullportfolio';
+    vm.url = vm.endpointSimple;
     vm.clientDestination = '/topic/greeting';
     vm.serverDestination = '/app/greeting';
     vm.connectHeaders = JSON.stringify({
@@ -46,6 +48,7 @@
 
 
     vm.connect = function () {
+      vm.debugLog = '';
       // use SockJS implementation instead of the browser's native implementation
       var options = {
         debug: true,
@@ -58,7 +61,8 @@
       var ws = new SockJS(vm.url, undefined, options);
       client = Stomp.over(ws);
       client.heartbeat.outgoing = 20000; // client will send heartbeats every 20000ms
-      client.heartbeat.incoming = 0;     // client does not want to receive heartbeats from the server
+      client.heartbeat.incoming = 20000; // server will send heartbeats every 20000ms
+      client.debug = stompClientDebug;
       client.connect(JSON.parse(vm.connectHeaders), connectCallback, errorCallback);
     };
 
@@ -85,7 +89,11 @@
 
     function errorCallback(error) {
       // display the error's message header:
-      alert(error.headers.message);
+      if (error.headers) {
+        alert(error.headers.message);
+      } else {
+        alert(error);
+      }
     }
 
     function subscribeCallback(message) {
@@ -100,6 +108,10 @@
     function disconnectCallback() {
       alert('See you next time!');
     }
+
+    function stompClientDebug(string) {
+        vm.debugLog = vm.debugLog + string + '\n';
+    }
   }
 
 })();

diff --git a/angularjs/stomp/src/stomp/app/example/example.html b/angularjs/stomp/src/stomp/app/example/example.html
index 283e7db..9a04771 100644 (file)
--- a/angularjs/stomp/src/stomp/app/example/example.html
+++ b/angularjs/stomp/src/stomp/app/example/example.html
@@ -7,7 +7,9 @@
 
     <label>
       Endpoint:<br>
-      <input value="http://localhost:8080" ng-model="vm.url" placeholder="url">
+      <textarea style="width: 200%; border: none">{{vm.endpointSimple}}</textarea><br>
+      <textarea style="width: 200%; border: none">{{vm.endpointFull}}</textarea><br>
+      <input value="http://localhost:8080" ng-model="vm.url" placeholder="url"/>
     </label>
     <br>
     <label>
@@ -35,7 +37,7 @@
 
     <label>
       Queue:<br>
-      <input value="/rpc/" ng-model="vm.clientDestination" placeholder="Client-Destination">
+      <input value="/rpc/" ng-model="vm.clientDestination" placeholder="Client-Destination"/>
     </label>
     <br>
     <label>
@@ -63,7 +65,7 @@
 
     <label>
       Server-Destination:<br>
-      <input value="/dest" ng-model="vm.serverDestination" placeholder="channel">
+      <input value="/dest" ng-model="vm.serverDestination" placeholder="channel"/>
     </label>
     <br>
     <label>
@@ -83,6 +85,13 @@
     </label>
   </div>
 
-  <textarea id="log"></textarea>
-
+  <div>
+    <br>
+    <label>
+      Output Debug:<br>
+      <textarea id="log" style="width: 200%; border: none" auto-height placeholder="log">
+        {{vm.debugLog}}
+      </textarea>
+    </label>
+  </div>
 </div>