diff --git a/server/mqtt.go b/server/mqtt.go index f52c41449..1b52b5ac8 100644 --- a/server/mqtt.go +++ b/server/mqtt.go @@ -272,6 +272,15 @@ func (m *MQTT) listenLoadpointSetters(topic string, site site.API, lp loadpoint. return err }) } + if err == nil { + err = m.Handler.ListenSetter(topic+"/limitEnergy", func(payload string) error { + energy, err := strconv.ParseFloat(payload, 64) + if err == nil { + lp.SetLimitEnergy(energy) + } + return err + }) + } if err == nil { err = m.Handler.ListenSetter(topic+"/planEnergy", func(payload string) error { var plan struct {