Loading apm-sniffer/apm-sdk-plugin/mongodb-2.x-plugin/src/main/java/org/skywalking/apm/plugin/mongodb/v2/MongoDBCollectionMethodInterceptor.java +2 −1 Original line number Diff line number Diff line Loading @@ -37,7 +37,8 @@ import org.skywalking.apm.agent.core.plugin.interceptor.enhance.MethodInterceptR import org.skywalking.apm.network.trace.component.ComponentsDefine; /** * {@link MongoDBCollectionMethodInterceptor} intercept {@link com.mongodb.DBCollectionImpl}{@link com.mongodb.DBCollection}class * {@link MongoDBCollectionMethodInterceptor} intercept {@link com.mongodb.DBCollectionImpl}{@link com.mongodb.DBCollection}class, * create the exit span when the client call the interceptor methods. */ public class MongoDBCollectionMethodInterceptor implements InstanceMethodsAroundInterceptor, InstanceConstructorInterceptor { Loading apm-sniffer/apm-sdk-plugin/mongodb-2.x-plugin/src/main/java/org/skywalking/apm/plugin/mongodb/v2/define/MongoDBCollectionInstrumentation.java +0 −3 Original line number Diff line number Diff line Loading @@ -86,9 +86,6 @@ public class MongoDBCollectionInstrumentation extends ClassInstanceMethodsEnhanc return named("findAndModify").and(takesArguments(9)); } }, /** *Involved db_command operation */ new InterceptPoint() { @Override public ElementMatcher<MethodDescription> getMethodsMatcher() { Loading apm-sniffer/apm-sdk-plugin/mongodb-3.x-plugin/src/main/java/org/skywalking/apm/plugin/mongodb/v3/MongoDBMethodInterceptor.java +1 −0 Original line number Diff line number Diff line Loading @@ -204,6 +204,7 @@ public class MongoDBMethodInterceptor implements InstanceMethodsAroundIntercepto ServerAddress address = description.getAddress(); peers.append(address.getHost() + ":" + address.getPort() + ";"); } objInst.setSkyWalkingDynamicField(peers.subSequence(0, peers.length() - 1).toString()); } } Loading
apm-sniffer/apm-sdk-plugin/mongodb-2.x-plugin/src/main/java/org/skywalking/apm/plugin/mongodb/v2/MongoDBCollectionMethodInterceptor.java +2 −1 Original line number Diff line number Diff line Loading @@ -37,7 +37,8 @@ import org.skywalking.apm.agent.core.plugin.interceptor.enhance.MethodInterceptR import org.skywalking.apm.network.trace.component.ComponentsDefine; /** * {@link MongoDBCollectionMethodInterceptor} intercept {@link com.mongodb.DBCollectionImpl}{@link com.mongodb.DBCollection}class * {@link MongoDBCollectionMethodInterceptor} intercept {@link com.mongodb.DBCollectionImpl}{@link com.mongodb.DBCollection}class, * create the exit span when the client call the interceptor methods. */ public class MongoDBCollectionMethodInterceptor implements InstanceMethodsAroundInterceptor, InstanceConstructorInterceptor { Loading
apm-sniffer/apm-sdk-plugin/mongodb-2.x-plugin/src/main/java/org/skywalking/apm/plugin/mongodb/v2/define/MongoDBCollectionInstrumentation.java +0 −3 Original line number Diff line number Diff line Loading @@ -86,9 +86,6 @@ public class MongoDBCollectionInstrumentation extends ClassInstanceMethodsEnhanc return named("findAndModify").and(takesArguments(9)); } }, /** *Involved db_command operation */ new InterceptPoint() { @Override public ElementMatcher<MethodDescription> getMethodsMatcher() { Loading
apm-sniffer/apm-sdk-plugin/mongodb-3.x-plugin/src/main/java/org/skywalking/apm/plugin/mongodb/v3/MongoDBMethodInterceptor.java +1 −0 Original line number Diff line number Diff line Loading @@ -204,6 +204,7 @@ public class MongoDBMethodInterceptor implements InstanceMethodsAroundIntercepto ServerAddress address = description.getAddress(); peers.append(address.getHost() + ":" + address.getPort() + ";"); } objInst.setSkyWalkingDynamicField(peers.subSequence(0, peers.length() - 1).toString()); } }