修改CI

sermant-io · Feb 25, 2025 · b7316e5 · b7316e5
1 parent ecdc31c
commit b7316e5
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...nt/mq/grayscale/rocketmq/interceptor/RocketMqSchedulerRebuildSubscriptionInterceptor.java b/...nt/mq/grayscale/rocketmq/interceptor/RocketMqSchedulerRebuildSubscriptionInterceptor.java
@@ -71,7 +71,7 @@ public ExecuteContext doAfter(ExecuteContext context) throws Exception {
     }
 
     private boolean isGrayTagChanged(ConcurrentMap<String, Object> map, RebalanceImpl balance,
-        List<Object> retrySubscriptionDatas) {
+            List<Object> retrySubscriptionDatas) {
         String topic = "";
         for (Object subscriptionData : map.values()) {
             String tempTopic = RocketMqReflectUtils.getTopic(subscriptionData);
@@ -86,21 +86,21 @@ private boolean isGrayTagChanged(ConcurrentMap<String, Object> map, RebalanceImp
 
     private void updateRetrySubscriptionData(Object subscriptionData, Collection<Object> retrySubscriptionDatas) {
         for (Object subData : retrySubscriptionDatas) {
-            String retryTopic = RocketMqReflectUtils.getTopic(subData);
-            String sqlSubstr = RocketMqReflectUtils.getSubString(subscriptionData);
             RocketMqReflectUtils.getTagsSet(subData).clear();
             RocketMqReflectUtils.getCodeSet(subData).clear();
             RocketMqReflectUtils.setSubscriptionDatae(subData, "setExpressionType",
                 new Class[]{String.class}, new Object[]{"SQL92"});
             RocketMqReflectUtils.setSubscriptionDatae(subData, "setSubVersion",
                 new Class[]{long.class}, new Object[]{System.currentTimeMillis()});
             String originSubData = RocketMqReflectUtils.getSubString(subData);
+            String sqlSubstr = RocketMqReflectUtils.getSubString(subscriptionData);
             RocketMqReflectUtils.setSubscriptionDatae(subData, "setSubString",
                 new Class[]{String.class}, new Object[]{sqlSubstr});
             String originTopic = RocketMqReflectUtils.getTopic(subscriptionData);
+            String retryTopic = RocketMqReflectUtils.getTopic(subData);
             LOGGER.warning(String.format(Locale.ENGLISH, "update retry topic [%s] SQL92 expression, "
                     + "originTopic: [%s], originSubStr: [%s], newSubStr: [%s]", retryTopic, originTopic,
-                originSubData, sqlSubstr));
+                    originSubData, sqlSubstr));
         }
     }