kazusa
/
skywalking
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

删除模拟埋点发送类

This commit is contained in:
zhangxin10 2015-11-10 19:44:29 +08:00
parent 4caf5eda7b
commit 1e79ad98e5
2 changed files with 5 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
skywalking-sdk-plugin/spring-plugin/src/main/java/com/ai/cloud/skywalking/plugin/spring/BuriedPointSender.java
View File

@ -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");
}
}

9
skywalking-sdk-plugin/spring-plugin/src/main/java/com/ai/cloud/skywalking/plugin/spring/TracingEnhanceProcessor.java
View File

@ -1,5 +1,6 @@
package com.ai.cloud.skywalking.plugin.spring; package com.ai.cloud.skywalking.plugin.spring;
import com.ai.cloud.skywalking.buriedpoint.LocalBuriedPointSender;
import com.ai.cloud.skywalking.model.SendData; import com.ai.cloud.skywalking.model.SendData;
import javassist.*; import javassist.*;
import org.springframework.beans.BeansException; import org.springframework.beans.BeansException;
@ -31,7 +32,7 @@ public class TracingEnhanceProcessor implements BeanPostProcessor {
// //
mCtc.setSuperclass(mPool.get(bean.getClass().getName())); 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)); mCtc.addField(CtField.make("private " + bean.getClass().getName() + " realBean;", mCtc));
// 校验方法 // 校验方法
for (Method method : methods) { for (Method method : methods) {
@ -48,13 +49,13 @@ public class TracingEnhanceProcessor implements BeanPostProcessor {
// TODO 参数注解 // TODO 参数注解
mCtc.addMethod(CtMethod.make(result.toString(), mCtc)); 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){" + .getName() + " buriedPoint, " + bean.getClass().getName() + " realBean){" +
"this.buriedPoint = buriedPoint;this.realBean = realBean;}", mCtc)); "this.buriedPoint = buriedPoint;this.realBean = realBean;}", mCtc));
mCtc.addConstructor(CtNewConstructor.defaultConstructor(mCtc)); mCtc.addConstructor(CtNewConstructor.defaultConstructor(mCtc));
Class classes = mCtc.toClass(); Class classes = mCtc.toClass();
Constructor constructor = classes.getConstructor(BuriedPointSender.class, bean.getClass()); Constructor constructor = classes.getConstructor(LocalBuriedPointSender.class, bean.getClass());
return constructor.newInstance(new BuriedPointSender(), bean); return constructor.newInstance(new LocalBuriedPointSender(), bean);
} catch (CannotCompileException e) { } catch (CannotCompileException e) {
e.printStackTrace(); e.printStackTrace();
} catch (InstantiationException e) { } catch (InstantiationException e) {