Topic emits (un)registered events.

registered_subscriber / unregistered_subscriber (and _publisher) are emitted when registered or unregistered with master.
baalexander · Apr 25, 2012 · 1cd4bcf · 1cd4bcf
1 parent 1ac8491
commit 1cd4bcf
Showing 1 changed file with 20 additions and 14 deletions.
diff --git a/lib/topic.js b/lib/topic.js
@@ -140,15 +140,18 @@ Topic.prototype.publish = function(message) {
 
     this.getUri(function(uri) {
       var masterParams = {
-          callerId    : that.node
-        , callerUri   : uri
-        , topic       : that.topic
-        , messageType : that.messageType.messageType
+        callerId    : that.node
+      , callerUri   : uri
+      , topic       : that.topic
+      , messageType : that.messageType.messageType
       };
       master.registerPublisher(masterParams, function(error) {
         if (error) {
           that.emit('error', error);
         }
+        else {
+          that.emit('registered_publisher');
+        }
       });
     });
   }
@@ -160,9 +163,9 @@ Topic.prototype.unpublish = function(message) {
   if (this.protocol) {
     this.getUri(function(uri) {
       var masterParams = {
-          callerId    : that.node
-        , callerUri   : uri
-        , topic       : that.topic
+        callerId    : that.node
+      , callerUri   : uri
+      , topic       : that.topic
       };
       master.unregisterPublisher(masterParams, function(error) {
         if (error) {
@@ -184,15 +187,18 @@ Topic.prototype.subscribe = function(callback) {
   if (!this.protocol) {
     this.getUri(function(uri) {
       var masterParams = {
-          callerId    : that.node
-        , callerUri   : uri
-        , topic       : that.topic
-        , messageType : that.messageType.messageType
+        callerId    : that.node
+      , callerUri   : uri
+      , topic       : that.topic
+      , messageType : that.messageType.messageType
       };
       master.registerSubscriber(masterParams, function(error) {
         if (error) {
           that.emit('error', error);
         }
+        else {
+          that.emit('registered_subscriber');
+        }
       });
     });
   }
@@ -204,9 +210,9 @@ Topic.prototype.unsubscribe = function(callback) {
   if (this.protocol) {
     this.getUri(function(uri) {
       var masterParams = {
-          callerId    : that.node
-        , callerUri   : uri
-        , topic       : that.topic
+        callerId    : that.node
+      , callerUri   : uri
+      , topic       : that.topic
       };
       master.unregisterSubscriber(masterParams, function(error) {
         if (error) {