调整设置版本方法setSubVersion

sermant-io · Dec 24, 2024 · 35e9b5a · 35e9b5a
1 parent 8a0fbe3
commit 35e9b5a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...n/src/main/java/io/sermant/mq/grayscale/rocketmq/utils/RocketMqSubscriptionDataUtils.java b/...n/src/main/java/io/sermant/mq/grayscale/rocketmq/utils/RocketMqSubscriptionDataUtils.java
@@ -292,7 +292,7 @@ public static void resetsSql92SubscriptionData(Object subscriptionData, String s
         }
         RocketMqReflectUtils.setSubscriptionDatae(subscriptionData, "setSubString",
                 new Class[]{String.class}, new Object[]{newSubStr});
-        RocketMqReflectUtils.setSubscriptionDatae(subscriptionData, "setSubString",
+        RocketMqReflectUtils.setSubscriptionDatae(subscriptionData, "setSubVersion",
                 new Class[]{Long.class}, new Object[]{System.currentTimeMillis()});
         LOGGER.warning(String.format(Locale.ENGLISH, "update [key: %s] SQL92 subscriptionData, originSubStr: "
                 + "[%s], newSubStr: [%s]", subscribeScope, originSubData, newSubStr));