dandri/beacon-server
1
0
Fork 0
mirror of https://github.com/MeshCore-Beacon/beacon-server.git synced 2026-09-02 00:58:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

add more broker connection timeout and retry defaults

Browse Source
This commit is contained in:
Enot (ded) Skelly
2026-06-03 14:05:58 -07:00
parent 8c71277de8
commit 42e455bd00
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/ingest/ingest.go
+7 -1
View File
@@ -392,12 +392,18 @@ func (w *Worker) Start(ctx context.Context) {
SetPassword(w.cfg.Password).
SetAutoReconnect(true).
SetMaxReconnectInterval(30 * time.Second).
SetKeepAlive(30 * time.Second).
SetPingTimeout(10 * time.Second).
SetConnectTimeout(15 * time.Second).
SetWriteTimeout(10 * time.Second).
SetConnectRetry(true).
SetConnectRetryInterval(5 * time.Second).
SetOnConnectHandler(func(c mqtt.Client) {
log.Printf("ingest[%s]: connected to %s", w.cfg.BrokerName, w.cfg.URL)
w.subscribe(c)
}).
SetConnectionLostHandler(func(_ mqtt.Client, err error) {
log.Printf("ingest[%s]: connection lost: %v", w.cfg.BrokerName, err)
log.Printf("ingest[%s]: connection lost, will reconnect: %v", w.cfg.BrokerName, err)
})
w.client = mqtt.NewClient(opts)