fix topic subscription

rainu · rainu · commit e06c729b6e09 · 2020-05-07T20:13:29.000+02:00
diff --git a/internal/mqtt/trigger.go b/internal/mqtt/trigger.go
@@ -47,7 +47,7 @@ func (t *Trigger) Initialise(subscribeQOS, publishQOS byte, triggerConfigs []con
 	t.triggerConfigs = triggerConfigs //safe the configs so that we can unsubscribe later (see Close func)
 
 	for _, triggerConf := range triggerConfigs {
-		t.subscriptions[triggerConf.Topic] = subscription{
+		t.subscriptions[triggerConf.Name] = subscription{
 			trigger: triggerConf,
 			handler: t.createTriggerHandler(triggerConf),
 		}

Original file line number	Diff line number	Diff line change
`@@ -47,7 +47,7 @@ func (t *Trigger) Initialise(subscribeQOS, publishQOS byte, triggerConfigs []con`
`47`	`47`	`t.triggerConfigs = triggerConfigs //safe the configs so that we can unsubscribe later (see Close func)`
`48`	`48`
`49`	`49`	`for _, triggerConf := range triggerConfigs {`
`50`		`- t.subscriptions[triggerConf.Topic] = subscription{`
	`50`	`+ t.subscriptions[triggerConf.Name] = subscription{`
`51`	`51`	`trigger: triggerConf,`
`52`	`52`	`handler: t.createTriggerHandler(triggerConf),`
`53`	`53`	`}`