diff --git a/skywalking-sdk-plugin/spring-plugin/src/main/java/com/ai/cloud/skywalking/plugin/spring/BuriedPointSender.java b/skywalking-sdk-plugin/spring-plugin/src/main/java/com/ai/cloud/skywalking/plugin/spring/BuriedPointSender.java deleted file mode 100644 index 510acfe55..000000000 --- a/skywalking-sdk-plugin/spring-plugin/src/main/java/com/ai/cloud/skywalking/plugin/spring/BuriedPointSender.java +++ /dev/null @@ -1,20 +0,0 @@ -package com.ai.cloud.skywalking.plugin.spring; - -import com.ai.cloud.skywalking.api.IBuriedPointSender; -import com.ai.cloud.skywalking.model.ContextData; -import com.ai.cloud.skywalking.model.SendData; - -public class BuriedPointSender implements IBuriedPointSender { - public ContextData beforeSend(SendData data) { - System.out.println("before Send"); - return null; - } - - public void afterSend() { - System.out.println("after Send"); - } - - public void handleException(Throwable th) { - System.out.println("handle Exception"); - } -} diff --git a/skywalking-sdk-plugin/spring-plugin/src/main/java/com/ai/cloud/skywalking/plugin/spring/TracingEnhanceProcessor.java b/skywalking-sdk-plugin/spring-plugin/src/main/java/com/ai/cloud/skywalking/plugin/spring/TracingEnhanceProcessor.java index 2a4db624e..d4489be84 100644 --- a/skywalking-sdk-plugin/spring-plugin/src/main/java/com/ai/cloud/skywalking/plugin/spring/TracingEnhanceProcessor.java +++ b/skywalking-sdk-plugin/spring-plugin/src/main/java/com/ai/cloud/skywalking/plugin/spring/TracingEnhanceProcessor.java @@ -1,5 +1,6 @@ package com.ai.cloud.skywalking.plugin.spring; +import com.ai.cloud.skywalking.buriedpoint.LocalBuriedPointSender; import com.ai.cloud.skywalking.model.SendData; import javassist.*; import org.springframework.beans.BeansException; @@ -31,7 +32,7 @@ public class TracingEnhanceProcessor implements BeanPostProcessor { // mCtc.setSuperclass(mPool.get(bean.getClass().getName())); //添加字段 - mCtc.addField(CtField.make("private " + BuriedPointSender.class.getName() + " buriedPoint;", mCtc)); + mCtc.addField(CtField.make("private " + LocalBuriedPointSender.class.getName() + " buriedPoint;", mCtc)); mCtc.addField(CtField.make("private " + bean.getClass().getName() + " realBean;", mCtc)); // 校验方法 for (Method method : methods) { @@ -48,13 +49,13 @@ public class TracingEnhanceProcessor implements BeanPostProcessor { // TODO 参数注解 mCtc.addMethod(CtMethod.make(result.toString(), mCtc)); } - mCtc.addConstructor(CtNewConstructor.make("public " + bean.getClass().getSimpleName() + "Proxy(" + BuriedPointSender.class + mCtc.addConstructor(CtNewConstructor.make("public " + bean.getClass().getSimpleName() + "Proxy(" + LocalBuriedPointSender.class .getName() + " buriedPoint, " + bean.getClass().getName() + " realBean){" + "this.buriedPoint = buriedPoint;this.realBean = realBean;}", mCtc)); mCtc.addConstructor(CtNewConstructor.defaultConstructor(mCtc)); Class classes = mCtc.toClass(); - Constructor constructor = classes.getConstructor(BuriedPointSender.class, bean.getClass()); - return constructor.newInstance(new BuriedPointSender(), bean); + Constructor constructor = classes.getConstructor(LocalBuriedPointSender.class, bean.getClass()); + return constructor.newInstance(new LocalBuriedPointSender(), bean); } catch (CannotCompileException e) { e.printStackTrace(); } catch (InstantiationException e) {