|
@@ -234,7 +234,7 @@ func main() {
|
|
User: g.Cfg().GetString("mqtt.user"),
|
|
User: g.Cfg().GetString("mqtt.user"),
|
|
Password: g.Cfg().GetString("mqtt.password"),
|
|
Password: g.Cfg().GetString("mqtt.password"),
|
|
Brokers: g.Cfg().GetStrings("mqtt.brokers"),
|
|
Brokers: g.Cfg().GetStrings("mqtt.brokers"),
|
|
- ConnNum: 10,
|
|
|
|
|
|
+ ConnNum: 1,
|
|
})
|
|
})
|
|
if err != nil {
|
|
if err != nil {
|
|
panic(err)
|
|
panic(err)
|