调整map名称

sermant-io · Feb 25, 2025 · 768dfc2 · 768dfc2
1 parent 768cf5c
commit 768dfc2
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/...nt/mq/grayscale/rocketmq/interceptor/RocketMqSchedulerRebuildSubscriptionInterceptor.java b/...nt/mq/grayscale/rocketmq/interceptor/RocketMqSchedulerRebuildSubscriptionInterceptor.java
@@ -47,13 +47,14 @@ public class RocketMqSchedulerRebuildSubscriptionInterceptor extends RocketMqAbs
 
     @Override
     public ExecuteContext doAfter(ExecuteContext context) throws Exception {
-        ConcurrentMap<String, Object> map = (ConcurrentMap<String, Object>) context.getResult();
+        ConcurrentMap<String, Object> subscriptionInner = (ConcurrentMap<String, Object>) context.getResult();
         RebalanceImpl balance = (RebalanceImpl) context.getObject();
         List<Object> retrySubscriptionDatas = new ArrayList<>();
-        if (balance.getConsumerGroup() == null || !isGrayTagChanged(map, balance, retrySubscriptionDatas)) {
+        if (balance.getConsumerGroup() == null
+            || !isGrayTagChanged(subscriptionInner, balance, retrySubscriptionDatas)) {
             return context;
         }
-        for (Object subscriptionData : map.values()) {
+        for (Object subscriptionData : subscriptionInner.values()) {
             String topic = RocketMqReflectUtils.getTopic(subscriptionData);
             if (topic.contains(RETRY_TOPIC_FLAG)) {
                 continue;
@@ -70,10 +71,10 @@ public ExecuteContext doAfter(ExecuteContext context) throws Exception {
         return context;
     }
 
-    private boolean isGrayTagChanged(ConcurrentMap<String, Object> map, RebalanceImpl balance,
+    private boolean isGrayTagChanged(ConcurrentMap<String, Object> subscriptionInner, RebalanceImpl balance,
             List<Object> retrySubscriptionDatas) {
         String topic = "";
-        for (Object subscriptionData : map.values()) {
+        for (Object subscriptionData : subscriptionInner.values()) {
             String tempTopic = RocketMqReflectUtils.getTopic(subscriptionData);
             if (!tempTopic.contains(RETRY_TOPIC_FLAG)) {
                 topic = tempTopic;