Fix linter error

Signed-off-by: shivam <[email protected]>
dapr · Oct 21, 2022 · bbae625 · bbae625
1 parent 8533feb
commit bbae625
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/pubsub/mqtt/mqtt.go b/pubsub/mqtt/mqtt.go
@@ -247,7 +247,6 @@ func (m *mqttPubSub) startSubscription(ctx context.Context) error {
 // onMessage returns the callback to be invoked when there's a new message from a topic
 func (m *mqttPubSub) onMessage(ctx context.Context) func(client mqtt.Client, mqttMsg mqtt.Message) {
 	return func(client mqtt.Client, mqttMsg mqtt.Message) {
-
 		ack := false
 		defer func() {
 			// Do not send N/ACKs on retained messages