add randomised start call delay

FlowFuse · Sep 9, 2024 · 22ae18b · 22ae18b
1 parent 8b1c63f
commit 22ae18b
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/lib/agent.js b/lib/agent.js
@@ -1,5 +1,6 @@
 const { IntervalJitter } = require('./IntervalJitter')
 const { existsSync } = require('fs')
+const { randomInt } = require('crypto')
 const fs = require('fs/promises')
 const path = require('path')
 const httpClient = require('./http')
@@ -135,6 +136,8 @@ class Agent {
                 }
                 // We have been provided a broker URL to use
                 this.mqttClient = mqttClient.newMQTTClient(this, this.config)
+                // Wait a short random delay to reduce stress on broker when large numbers of devices come on-line 
+                await new Promise(r => setTimeout(r, randomInt(20, 5000)));
                 this.mqttClient.start()
                 this.mqttClient.setApplication(this.currentApplication)
                 this.mqttClient.setProject(this.currentProject)