Fix MQTT3 component (#3501)

mikeee · web-flow · commit e53cf3401fd5 · 2024-08-02T10:37:20.000-07:00
Signed-off-by: mikeee &lt;hey@mike.ee&gt;
diff --git a/pubsub/mqtt3/mqtt.go b/pubsub/mqtt3/mqtt.go
@@ -181,8 +181,6 @@ func (m *mqttPubSub) Subscribe(ctx context.Context, req pubsub.SubscribeRequest,
 		}
 
 		// Delete the topic from the map first, which stops routing messages to handlers
-		m.subscribingLock.Lock()
-		defer m.subscribingLock.Unlock()
 		delete(m.topics, topic)
 
 		// We will call Unsubscribe only if cleanSession is true or if "unsubscribeOnClose" in the request metadata is true

Original file line number	Diff line number	Diff line change
`@@ -181,8 +181,6 @@ func (m *mqttPubSub) Subscribe(ctx context.Context, req pubsub.SubscribeRequest,`
`181`	`181`	`}`
`182`	`182`
`183`	`183`	`// Delete the topic from the map first, which stops routing messages to handlers`
`184`		`- m.subscribingLock.Lock()`
`185`		`- defer m.subscribingLock.Unlock()`
`186`	`184`	`delete(m.topics, topic)`
`187`	`185`
`188`	`186`	`// We will call Unsubscribe only if cleanSession is true or if "unsubscribeOnClose" in the request metadata is true`