增加测试

sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/FilterExtendDeclare.java

@@ -0,0 +1,24 @@
+package io.sermant.flowcontrol;
+
+import io.sermant.core.plugin.agent.declarer.AbstractPluginDeclarer;
+import io.sermant.core.plugin.agent.declarer.InterceptDeclarer;
+import io.sermant.core.plugin.agent.matcher.ClassMatcher;
+import io.sermant.core.plugin.agent.matcher.MethodMatcher;
+
+public class FilterExtendDeclare extends AbstractPluginDeclarer {
+  private static final String ENHANCE_CLASS = "org.apache.dubbo.rpc.BaseFilter";
+
+  private static final String INTERCEPT_CLASS = FilterExtendTestInterceptor.class.getCanonicalName();
+
+  @Override
+  public ClassMatcher getClassMatcher() {
+    return ClassMatcher.isExtendedFrom(ENHANCE_CLASS);
+  }
+
+  @Override
+  public InterceptDeclarer[] getInterceptDeclarers(ClassLoader classLoader) {
+    return new InterceptDeclarer[]{
+        InterceptDeclarer.build(MethodMatcher.nameEquals("invoke"), INTERCEPT_CLASS)
+    };
+  }
+}

sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/FilterExtendTestInterceptor.java

@@ -0,0 +1,36 @@
+package io.sermant.flowcontrol;
+
+import java.util.logging.Logger;
+
+import org.apache.dubbo.common.Version;
+
+import io.sermant.core.common.LoggerFactory;
+import io.sermant.core.plugin.agent.entity.ExecuteContext;
+import io.sermant.core.plugin.agent.interceptor.Interceptor;
+
+public class FilterExtendTestInterceptor implements Interceptor {
+  private static final Logger LOGGER = LoggerFactory.getLogger();
+
+  @Override
+  public ExecuteContext before(ExecuteContext context) throws Exception {
+    Object invoke = context.getArguments()[0];
+    String currentVersion = invoke.getClass().getPackage().getImplementationVersion();
+    if (currentVersion == null) {
+      currentVersion = Version.getVersion();
+    }
+    LOGGER.info("===========================>find version:" + currentVersion);
+    String className = context.getObject().getClass().getCanonicalName();
+    LOGGER.info("===========================>current filter name:" + className);
+    return context;
+  }
+
+  @Override
+  public ExecuteContext after(ExecuteContext context) throws Exception {
+    return context;
+  }
+
+  @Override
+  public ExecuteContext onThrow(ExecuteContext context) throws Exception {
+    return context;
+  }
+}

sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/FutureFilterDeclarer.java → sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/java/io/sermant/flowcontrol/RouterSnapshotFilterDeclarer.java

@@ -23,15 +23,15 @@
  * @author chengyouling
  * @since 2025-02-27
  */
-public class FutureFilterDeclarer extends DubboDeclarer {
-    private static final String ENHANCE_CLASS = "org.apache.dubbo.rpc.protocol.dubbo.filter.FutureFilter";
+public class RouterSnapshotFilterDeclarer extends DubboDeclarer {
+    private static final String ENHANCE_CLASS = "org.apache.dubbo.rpc.cluster.router.RouterSnapshotFilter";
 
     private static final String INTERCEPT_CLASS = ApacheDubboInterceptor.class.getCanonicalName();
 
     /**
      * apache dubbo Declarer
      */
-    public FutureFilterDeclarer() {
+    public RouterSnapshotFilterDeclarer() {
         super(ENHANCE_CLASS, INTERCEPT_CLASS);
     }
 }

sermant-plugins/sermant-flowcontrol/flowcontrol-plugin/src/main/resources/META-INF/services/io.sermant.core.plugin.agent.declarer.PluginDeclarer

@@ -14,12 +14,12 @@
 # limitations under the License.
 #
 #
-
+io.sermant.flowcontrol.FilterExtendDeclare
 io.sermant.flowcontrol.DispatcherServletDeclarer
 io.sermant.flowcontrol.AlibabaDubboDeclarer
 io.sermant.flowcontrol.ApacheDubboDeclarer
 io.sermant.flowcontrol.ConsumerRpcExceptionFilterDeclarer
-io.sermant.flowcontrol.FutureFilterDeclarer
+io.sermant.flowcontrol.RouterSnapshotFilterDeclarer
 io.sermant.flowcontrol.ConsumerContextFilterDeclarer
 io.sermant.flowcontrol.config.DubboServiceNameDeclarer
 io.sermant.flowcontrol.config.ApacheDubboConfigDeclarer