From e53cf3401fd53737c7d1d2782cb5ccd44f099b41 Mon Sep 17 00:00:00 2001 From: Mike Nguyen Date: Fri, 2 Aug 2024 18:37:20 +0100 Subject: [PATCH] Fix MQTT3 component (#3501) Signed-off-by: mikeee --- pubsub/mqtt3/mqtt.go | 2 -- 1 file changed, 2 deletions(-) diff --git a/pubsub/mqtt3/mqtt.go b/pubsub/mqtt3/mqtt.go index 5a59d3afc7..f36a7ceb37 100644 --- 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