Skip to content

Commit adf0eaa

Browse files
committed
fixed the build
1 parent 5de871b commit adf0eaa

File tree

1 file changed

+3
-6
lines changed

1 file changed

+3
-6
lines changed

src/SuperSocket.MQTT.Server/TopicMiddleware.cs

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -43,16 +43,13 @@ void ITopicManager.UnsubscribeTopic(MQTTSession session, string topic)
4343

4444
public override ValueTask<bool> UnRegisterSession(IAppSession session)
4545
{
46-
var topics = (session as MQTTSession).TopicNames;
46+
var topics = (session as MQTTSession).Topics;
4747

4848
foreach (var topic in topics)
4949
{
50-
foreach (var topicFilter in topic.TopicFilters)
50+
if (_topics.TryGetValue(topic.Topic, out var subscribedSessions))
5151
{
52-
if (_topics.TryGetValue(topicFilter.Topic, out var subscribedSessions))
53-
{
54-
subscribedSessions.Remove(session.SessionID, out _);
55-
}
52+
subscribedSessions.Remove(session.SessionID, out _);
5653
}
5754
}
5855

0 commit comments

Comments
 (0)