From 55c0ba4c87ddeaa928fdbf0db16110750682159b Mon Sep 17 00:00:00 2001
From: Steven Lazidis <the1laz@users.noreply.github.com>
Date: Sun, 18 Aug 2019 12:47:32 +0000
Subject: [PATCH] Added setting for changing interval for message queues

---
 index.js    | 5 +++--
 settings.js | 1 +
 2 files changed, 4 insertions(+), 2 deletions(-)
 mode change 100644 => 100755 index.js

diff --git a/index.js b/index.js
old mode 100644
new mode 100755
index d2923dd..5f57009
--- 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
index b1497d7..46930f1 100644
--- 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;