node-red-contrib-kafka-client - npm Package Compare versions

Comparing version 0.0.4 to 0.0.5

js/kafka-producer.js

@@ -7,3 +7,3 @@ module.exports = function(RED) {
         var node = this;
-        var ready = false;
+        node.ready = false;
     
@@ -21,3 +21,3 @@ let broker = RED.nodes.getNode(config.broker);
         node.onError = function(err){
-            ready = false;
+            node.ready = false;
             node.status({fill:"red",shape:"ring",text:"Error"});
@@ -28,3 +28,3 @@ node.error(err);
         node.onReady = function(){
-            ready = true;
+            node.ready = true;
             node.status({fill:"green",shape:"ring",text:"Ready"});
@@ -42,14 +42,17 @@ }
         node.on('input', function(msg) {
-            sendOptions.messages =[msg.payload];
-            node.producer.send([sendOptions],function (err) {
-                if(!err){
-                    node.status({fill:"blue",shape:"ring",text:"Sending"});
-                }
-                else{
-                    node.status({fill:"red",shape:"ring",text:"Error"});
-                }
-            });
+            if(node.ready){
+                sendOptions.messages =[msg.payload];
+                node.producer.send([sendOptions],function (err) {
+                    if(!err){
+                        node.status({fill:"blue",shape:"ring",text:"Sending"});
+                    }
+                    else{
+                        node.status({fill:"red",shape:"ring",text:"Error"});
+                    }
+                });
+            }
         });
 
         node.on('close', function(){
+            node.ready = false;
             node.status({});
@@ -56,0 +59,0 @@ node.producer.removeListener('ready', node.onReady);

package.json

 {
     "name": "node-red-contrib-kafka-client",
-    "version": "0.0.4",
+    "version": "0.0.5",
     "description": "Node-RED Kafka Consumer and Producer",
@@ -5,0 +5,0 @@ "node-red": {

No alert changes

Improved metrics

Total package byte prevSize

87677

increased by0.14%

Lines of code

119

increased by2.59%

No dependency changes