8 duplicated lines in:
  - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/MqttMessageUpContext.java (34:47, 38%)
  - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/Session.java (104:117, 2%)

6 duplicated lines in:
  - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Message.java (219:225, 3%)
  - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/QueueCache.java (129:135, 2%)

6 duplicated lines in:
  - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/MessageEvent.java (29:35, 18%)
  - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/QueueCache.java (129:135, 2%)

6 duplicated lines in:
  - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Subscription.java (69:75, 11%)
  - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java (608:614, 1%)

6 duplicated lines in:
  - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Message.java (219:225, 3%)
  - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java (608:614, 1%)

6 duplicated lines in:
  - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/MessageEvent.java (29:35, 18%)
  - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java (608:614, 1%)

6 duplicated lines in:
  - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Queue.java (78:84, 11%)
  - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/QueueCache.java (129:135, 2%)

6 duplicated lines in:
  - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Subscription.java (69:75, 11%)
  - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/QueueCache.java (129:135, 2%)

6 duplicated lines in:
  - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Queue.java (78:84, 11%)
  - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java (608:614, 1%)