Added setting for changing interval for message queues

the1laz · Aug 18, 2019 · 55c0ba4 · 55c0ba4
1 parent 6877609
commit 55c0ba4
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/index.js b/index.js
@@ -21,6 +21,7 @@ var commandConnected = false;
 var eventConnected = false;
 var buffer = "";
 var eventEmitter = new events.EventEmitter();
+var messageinterval = settings.messageinterval || 200;
 
 // MQTT URL
 var mqtt_url = url.parse('mqtt://'+settings.mqtt);
@@ -41,7 +42,7 @@ var queue =  {
   publish: function (topic, payload ) {
     queue.queue.push({topic:topic,payload:payload})
     if(queue.interval === null) {
-      queue.interval = setInterval(queue.process,100)
+      queue.interval = setInterval(queue.process,messageinterval)
       queue.process()
     }
   },
@@ -62,7 +63,7 @@ var queue2 =  {
   write: function (value) {
     queue2.queue.push(value)
     if(queue2.interval === null) {
-      queue2.interval = setInterval(queue2.process,100)
+      queue2.interval = setInterval(queue2.process,messageinterval)
       queue2.process()
     }
   },

diff --git a/settings.js b/settings.js
@@ -25,6 +25,7 @@ exports.mqtt = '127.0.0.1:1883';
 // Sets MQTT retain flag for values coming from cgate
 // exports.retainreads = true;
 
+exports.messageinterval = 200;
 
 //logging
 exports.logging = false;