fix source config issue

Signed-off-by: Jeeva Kandasamy <jkandasa@gmail.com>
mycontroller-org · Jul 16, 2021 · a855bc8 · a855bc8
1 parent 504a820
commit a855bc8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/service/adapter/service.go b/pkg/service/adapter/service.go
@@ -245,7 +245,7 @@ func (s *Service) reconnectSourceDevice() {
 		}
 	}
 
-	sourceDevice, err := devicePlugin.Create(s.adapterConfig.Source.GetString(model.KeyType), s.adapterConfig.Name, s.adapterConfig.MQTT, s.onSourceMessage, s.onSourceStatus)
+	sourceDevice, err := devicePlugin.Create(s.adapterConfig.Source.GetString(model.KeyType), s.adapterConfig.Name, s.adapterConfig.Source, s.onSourceMessage, s.onSourceStatus)
 	if err == nil {
 		s.sourceDevice = sourceDevice
 		// update status UP