Release 2.0.3

Author: knalli

CHANGELOG.md

@@ -1,3 +1,13 @@
+<a name"2.0.3"></a>
+### 2.0.3 (2015-06-22)
+
+
+#### Bug Fixes
+
+* **demo:** Replace CoffeeScript w/ BabelJS runner ([4dc71a07](https://github.com/knalli/angular-vertxbus/commit/4dc71a07))
+* **service:** fix doubled handler registration in special circumstances ([f3311ca5](https://github.com/knalli/angular-vertxbus/commit/f3311ca5))
+
+
 <a name"2.0.2"></a>
 ### 2.0.2 (2015-06-15)
 

dist/angular-vertxbus.js

@@ -1,4 +1,4 @@
-/*! angular-vertxbus - v2.0.2 - 2015-06-15
+/*! angular-vertxbus - v2.0.3 - 2015-06-22
 * http://github.com/knalli/angular-vertxbus
 * Copyright (c) 2015 Jan Philipp; Licensed MIT */
 (function e(t,n,r){function s(o,u){if(!n[o]){if(!t[o]){var a=typeof require=="function"&&require;if(!u&&a)return a(o,!0);if(i)return i(o,!0);var f=new Error("Cannot find module '"+o+"'");throw f.code="MODULE_NOT_FOUND",f}var l=n[o]={exports:{}};t[o][0].call(l.exports,function(e){var n=t[o][1][e];return s(n?n:e)},l,l.exports,e,t,n,r)}return n[o].exports}var i=typeof require=="function"&&require;for(var o=0;o<r.length;o++)s(r[o]);return s})({1:[function(require,module,exports){
@@ -615,13 +615,19 @@ var LiveDelegate = (function (_BaseDelegate) {
 
     // internal
     value: function onEventbusOpen() {
+      var connectionStateFlipped = false;
       this.getConnectionState(true);
       if (!this.states.connected) {
         this.states.connected = true;
-        this.$rootScope.$broadcast('' + this.options.prefix + 'system.connected');
+        connectionStateFlipped = true;
       }
+      // Ensure all events will be re-attached
       this.afterEventbusConnected();
-      this.$rootScope.$digest();
+      // Everything is online and registered again, let's notify everybody
+      if (connectionStateFlipped) {
+        this.$rootScope.$broadcast('' + this.options.prefix + 'system.connected');
+      }
+      this.$rootScope.$digest(); // explicitly
       // consume message queue?
       if (this.options.messageBuffer && this.messageQueue.size()) {
         while (this.messageQueue.size()) {
@@ -718,6 +724,7 @@ var LiveDelegate = (function (_BaseDelegate) {
       }
       if (this.options.debugEnabled) {
         this.$log.debug('[Vert.x EB Service] Register handler for ' + address);
+        console.trace();
       }
       var callbackWrapper = function callbackWrapper(message, replyTo) {
         callback(message, replyTo);
@@ -1323,7 +1330,7 @@ var EventbusWrapper = (function (_BaseWrapper) {
           _this.disconnectTimeoutEnabled = true;
           _this.connect();
         } else if (_this.options.reconnectEnabled) {
-          // automatical reconnect after timeout
+          // automatic reconnect after timeout
           if (_this.options.debugEnabled) {
             _this.$log.debug('[Vert.x EB Stub] Reconnect in ' + _this.options.sockjsReconnectInterval + 'ms');
           }