File tree 2 files changed +8
-8
lines changed
client/src/main/java/org/apache/rocketmq/client/impl/consumer
2 files changed +8
-8
lines changed Original file line number Diff line number Diff line change @@ -1084,12 +1084,12 @@ private void resetTopic(List<MessageExt> msgList) {
1084
1084
}
1085
1085
1086
1086
//If namespace not null , reset Topic without namespace.
1087
- for (MessageExt messageExt : msgList ) {
1088
- if (null != this .defaultLitePullConsumer .getNamespace ()) {
1089
- messageExt .setTopic (NamespaceUtil .withoutNamespace (messageExt .getTopic (), this .defaultLitePullConsumer .getNamespace ()));
1087
+ String namespace = this .defaultLitePullConsumer .getNamespace ();
1088
+ if (namespace != null ) {
1089
+ for (MessageExt messageExt : msgList ) {
1090
+ messageExt .setTopic (NamespaceUtil .withoutNamespace (messageExt .getTopic (), namespace ));
1090
1091
}
1091
1092
}
1092
-
1093
1093
}
1094
1094
1095
1095
public void updateConsumeOffset (MessageQueue mq , long offset ) {
Original file line number Diff line number Diff line change @@ -290,12 +290,12 @@ public void resetTopic(List<MessageExt> msgList) {
290
290
}
291
291
292
292
//If namespace not null , reset Topic without namespace.
293
- for (MessageExt messageExt : msgList ) {
294
- if (null != this .getDefaultMQPullConsumer ().getNamespace ()) {
295
- messageExt .setTopic (NamespaceUtil .withoutNamespace (messageExt .getTopic (), this .defaultMQPullConsumer .getNamespace ()));
293
+ String namespace = this .getDefaultMQPullConsumer ().getNamespace ();
294
+ if (namespace != null ) {
295
+ for (MessageExt messageExt : msgList ) {
296
+ messageExt .setTopic (NamespaceUtil .withoutNamespace (messageExt .getTopic (), namespace ));
296
297
}
297
298
}
298
-
299
299
}
300
300
301
301
public void subscriptionAutomatically (final String topic ) {
You can’t perform that action at this time.
0 commit comments