修改CI

sermant-io · Sep 4, 2024 · 9a0da0b · 9a0da0b
1 parent 7b85152
commit 9a0da0b
Show file tree

Hide file tree

Showing 4 changed files with 18 additions and 6 deletions.
diff --git a/...scale-plugin/src/main/java/io/sermant/mq/grayscale/interceptor/MqAbstractIntercepter.java b/...scale-plugin/src/main/java/io/sermant/mq/grayscale/interceptor/MqAbstractIntercepter.java
@@ -47,10 +47,26 @@ public ExecuteContext after(ExecuteContext context) throws Exception {
         return doAfter(context);
     }
 
+    /**
+     * Handling after the intercept point
+     *
+     * @param context context
+     * @return context
+     * @throws Exception Exception
+     */
     protected ExecuteContext doAfter(ExecuteContext context) throws Exception {
         return context;
     }
 
+    /**
+     * build gray group name and set consumer client configs
+     *
+     * @param consumer consumer
+     * @param namesrvAddr namesrvAddr
+     * @param topic topic
+     * @param consumerGroup consumerGroup
+     * @throws Exception Exception
+     */
     protected void buildGroupAndClientConfig(Object consumer, String namesrvAddr, String topic, String consumerGroup)
             throws Exception {
         String grayGroupTag = MqGrayscaleConfigUtils.getGrayGroupTag();

diff --git a/...main/java/io/sermant/mq/grayscale/interceptor/MqLitePullConsumerSubscribeInterceptor.java b/...main/java/io/sermant/mq/grayscale/interceptor/MqLitePullConsumerSubscribeInterceptor.java
@@ -31,7 +31,7 @@
  **/
 public class MqLitePullConsumerSubscribeInterceptor extends MqAbstractIntercepter {
     @Override
-    public ExecuteContext doAfter(ExecuteContext context) throws Exception{
+    public ExecuteContext doAfter(ExecuteContext context) throws Exception {
         DefaultLitePullConsumerImpl litePullConsumerImpl = (DefaultLitePullConsumerImpl) context.getObject();
         DefaultLitePullConsumer pullConsumer = litePullConsumerImpl.getDefaultLitePullConsumer();
         buildGroupAndClientConfig(pullConsumer, pullConsumer.getNamesrvAddr(), (String) context.getArguments()[0],

diff --git a/...n/java/io/sermant/mq/grayscale/interceptor/MqSchedulerRebuildSubscriptionInterceptor.java b/...n/java/io/sermant/mq/grayscale/interceptor/MqSchedulerRebuildSubscriptionInterceptor.java
@@ -16,7 +16,6 @@
 
 package io.sermant.mq.grayscale.interceptor;
 
-import io.sermant.core.common.LoggerFactory;
 import io.sermant.core.plugin.agent.entity.ExecuteContext;
 import io.sermant.core.utils.StringUtils;
 import io.sermant.mq.grayscale.service.MqConsumerGroupAutoCheck;
@@ -27,9 +26,7 @@
 import org.apache.rocketmq.client.impl.factory.MQClientInstance;
 import org.apache.rocketmq.common.protocol.heartbeat.SubscriptionData;
 
-import java.util.Locale;
 import java.util.concurrent.ConcurrentMap;
-import java.util.logging.Logger;
 
 /**
  * TAG/SQL92 query message statement interceptor
@@ -38,8 +35,6 @@
  * @since 2024-05-27
  **/
 public class MqSchedulerRebuildSubscriptionInterceptor extends MqAbstractIntercepter {
-    private static final Logger LOGGER = LoggerFactory.getLogger();
-
     private final Object lock = new Object();
 
     @Override

diff --git a/...q-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/utils/SubscriptionDataUtils.java b/...q-grayscale-plugin/src/main/java/io/sermant/mq/grayscale/utils/SubscriptionDataUtils.java
@@ -410,6 +410,7 @@ public static void resetTagChangeMap(String namesrvAddr, String topic, String co
 
     /**
      * check expressionType is inaccurate
+     *
      * @param expressionType expressionType
      * @return is inaccurate
      */
-Original file line number
+Diff line change
@@ Expand Up @@
         /**
          * check expressionType is inaccurate
+         *
          * @param expressionType expressionType
          * @return is inaccurate
          */
@@ Expand Down @@