Blame SOURCES/0003-fix-report-active-dispatchers-when-connecting-to-bro.patch
|
 |
af1c57 |
From 7c742868fbcb0f7fbd2d9d1e02991bbb01e2d763 Mon Sep 17 00:00:00 2001
|
|
|
af1c57 |
From: Link Dupont <link@sub-pop.net>
|
|
|
af1c57 |
Date: Fri, 24 Sep 2021 15:12:45 -0400
|
|
|
af1c57 |
Subject: [PATCH] fix: report active dispatchers when connecting to broker
|
|
|
af1c57 |
|
|
|
af1c57 |
Include the current dispatchers map when publishing connection status during the reconnect handler instead of always publishing an empty map.
|
|
|
af1c57 |
|
|
|
af1c57 |
Fixes RHBZ#2007667
|
|
|
af1c57 |
|
|
|
af1c57 |
Signed-off-by: Link Dupont <link@sub-pop.net>
|
|
|
af1c57 |
---
|
|
|
af1c57 |
cmd/yggd/main.go | 2 +-
|
|
|
af1c57 |
1 file changed, 1 insertion(+), 1 deletion(-)
|
|
|
af1c57 |
|
|
|
af1c57 |
diff --git a/cmd/yggd/main.go b/cmd/yggd/main.go
|
|
|
af1c57 |
index 5f0a931..4999f98 100644
|
|
|
af1c57 |
--- a/cmd/yggd/main.go
|
|
|
af1c57 |
+++ b/cmd/yggd/main.go
|
|
|
af1c57 |
@@ -238,7 +238,7 @@ func main() {
|
|
|
af1c57 |
})
|
|
|
af1c57 |
log.Tracef("subscribed to topic: %v", topic)
|
|
|
af1c57 |
|
|
|
af1c57 |
- go publishConnectionStatus(client, map[string]map[string]string{})
|
|
|
af1c57 |
+ go publishConnectionStatus(client, d.makeDispatchersMap())
|
|
|
af1c57 |
})
|
|
|
af1c57 |
mqttClientOpts.SetDefaultPublishHandler(func(c mqtt.Client, m mqtt.Message) {
|
|
|
af1c57 |
log.Errorf("unhandled message: %v", string(m.Payload()))
|
|
|
af1c57 |
--
|
|
|
af1c57 |
2.31.1
|
|
|
af1c57 |
|