Do not subscribe to MQTT in SubsribeStream

FZambia · atifali · web-flow · commit fc5be300e714 · 2021-06-01T15:18:49.000+03:00
Co-authored-by: Atif Shoukat Ali &lt;atifshoukatali@yahoo.com&gt;
diff --git a/pkg/plugin/datasource.go b/pkg/plugin/datasource.go
@@ -102,8 +102,6 @@ func (ds *MQTTDatasource) CheckHealth(_ context.Context, _ *backend.CheckHealthR
 }
 
 func (ds *MQTTDatasource) SubscribeStream(_ context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error) {
-	ds.Client.Subscribe(req.Path)
-
 	return &backend.SubscribeStreamResponse{
 		Status: backend.SubscribeStreamStatusOK,
 	}, nil

Original file line number	Diff line number	Diff line change
`@@ -102,8 +102,6 @@ func (ds MQTTDatasource) CheckHealth(_ context.Context, _ backend.CheckHealthR`
`102`	`102`	`}`
`103`	`103`
`104`	`104`	`func (ds MQTTDatasource) SubscribeStream(_ context.Context, req backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error) {`
`105`		`- ds.Client.Subscribe(req.Path)`
`106`		`-`
`107`	`105`	`return &backend.SubscribeStreamResponse{`
`108`	`106`	`Status: backend.SubscribeStreamStatusOK,`
`109`	`107`	`}, nil`