mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/Session.java [385:391]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        Map<Queue, LinkedHashSet<Message>> tmp = sendingMessages.get(subscription);
        if (tmp != null && !tmp.isEmpty()) {
            LinkedHashSet<Message> messages = tmp.get(queue);
            if (messages == null) {
                return null;
            }
            synchronized (this) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/Session.java [406:412]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        Map<Queue, LinkedHashSet<Message>> tmp = sendingMessages.get(subscription);
        if (tmp != null && !tmp.isEmpty()) {
            LinkedHashSet<Message> messages = tmp.get(queue);
            if (messages == null) {
                return null;
            }
            synchronized (this) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -