mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/match/MatchAction.java [107:117]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        String channelId = session.getChannelId();
        if (channelId == null || subscriptions == null || subscriptions.isEmpty()) {
            return;
        }
        for (Subscription subscription : subscriptions) {
            if (subscription.isRetry() || subscription.isP2p()) {
                continue;
            }
            String topicFilter = subscription.getTopicFilter();
            boolean isWildCard = TopicUtils.isWildCard(topicFilter);
            if (isWildCard) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/match/MatchAction.java [130:140]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        String channelId = session.getChannelId();
        if (channelId == null || subscriptions == null || subscriptions.isEmpty()) {
            return;
        }
        for (Subscription subscription : subscriptions) {
            if (subscription.isRetry() || subscription.isP2p()) {
                continue;
            }
            String topicFilter = subscription.getTopicFilter();
            boolean isWildCard = TopicUtils.isWildCard(topicFilter);
            if (isWildCard) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -