avoid publishing to a closed ascoltatore

moscajs · Mar 22, 2016 · 983440a · 983440a
1 parent 19634f4
commit 983440a
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/lib/kafka_ascoltatore.js b/lib/kafka_ascoltatore.js
@@ -168,7 +168,9 @@ KafkaAscoltatore.prototype._startConn = function(cb) {
                 if(message.value && encoding !== "buffer"){
                   value = message.value.toString(encoding);
                 }
-              that._ascoltatore.publish(that._recvTopic(message.topic), value);
+               if(that._ascoltatore._closed !== true){
+                  that._ascoltatore.publish(that._recvTopic(message.topic), value);
+               }
           };
           publish();
         });