From 1e79ad98e5c0f913c905a7558aaee3c9f3dbaba0 Mon Sep 17 00:00:00 2001 From: zhangxin10 Date: Tue, 10 Nov 2015 19:44:29 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4=E6=A8=A1=E6=8B=9F=E5=9F=8B?= =?UTF-8?q?=E7=82=B9=E5=8F=91=E9=80=81=E7=B1=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../plugin/spring/BuriedPointSender.java | 20 ------------------- .../spring/TracingEnhanceProcessor.java | 9 +++++---- 2 files changed, 5 insertions(+), 24 deletions(-) delete mode 100644 skywalking-sdk-plugin/spring-plugin/src/main/java/com/ai/cloud/skywalking/plugin/spring/BuriedPointSender.java 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) {