From 1a8fb0f181a737df7fe8e6fbaf6f63f3379e7012 Mon Sep 17 00:00:00 2001 From: lytscu Date: Mon, 29 Jan 2018 20:08:29 +0800 Subject: [PATCH] Modify operationName to invocation.getMicroserviceQualifiedName() --- .../apm/plugin/servicecomb/InvocationInterceptor.java | 2 +- .../skywalking/apm/plugin/servicecomb/NextInterceptor.java | 2 +- .../apm/plugin/servicecomb/InvocationInterceptorTest.java | 2 +- .../skywalking/apm/plugin/servicecomb/NextInterceptorTest.java | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/apm-sniffer/apm-sdk-plugin/servicecomb-plugin/servicecomb-java-chassis-0.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/servicecomb/InvocationInterceptor.java b/apm-sniffer/apm-sdk-plugin/servicecomb-plugin/servicecomb-java-chassis-0.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/servicecomb/InvocationInterceptor.java index 5a76896d2..e76a4e0c4 100644 --- a/apm-sniffer/apm-sdk-plugin/servicecomb-plugin/servicecomb-java-chassis-0.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/servicecomb/InvocationInterceptor.java +++ b/apm-sniffer/apm-sdk-plugin/servicecomb-plugin/servicecomb-java-chassis-0.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/servicecomb/InvocationInterceptor.java @@ -58,7 +58,7 @@ public class InvocationInterceptor implements InstanceMethodsAroundInterceptor { next = next.next(); next.setHeadValue(invocation.getContext().get(next.getHeadKey())); } - String operationName = invocation.getInvocationQualifiedName(); + String operationName = invocation.getMicroserviceQualifiedName(); span = ContextManager.createEntrySpan(operationName, contextCarrier); String url = invocation.getOperationMeta().getOperationPath(); Tags.URL.set(span, url); diff --git a/apm-sniffer/apm-sdk-plugin/servicecomb-plugin/servicecomb-java-chassis-0.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/servicecomb/NextInterceptor.java b/apm-sniffer/apm-sdk-plugin/servicecomb-plugin/servicecomb-java-chassis-0.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/servicecomb/NextInterceptor.java index bde064c99..2abc0d7aa 100644 --- a/apm-sniffer/apm-sdk-plugin/servicecomb-plugin/servicecomb-java-chassis-0.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/servicecomb/NextInterceptor.java +++ b/apm-sniffer/apm-sdk-plugin/servicecomb-plugin/servicecomb-java-chassis-0.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/servicecomb/NextInterceptor.java @@ -66,7 +66,7 @@ public class NextInterceptor implements InstanceMethodsAroundInterceptor { URI uri = new URI(invocation.getEndpoint().toString()); String peer = uri.getHost() + ":" + uri.getPort(); final ContextCarrier contextCarrier = new ContextCarrier(); - span = ContextManager.createExitSpan(invocation.getInvocationQualifiedName(), contextCarrier, peer); + span = ContextManager.createExitSpan(invocation.getMicroserviceQualifiedName(), contextCarrier, peer); CarrierItem next = contextCarrier.items(); while (next.hasNext()) { next = next.next(); diff --git a/apm-sniffer/apm-sdk-plugin/servicecomb-plugin/servicecomb-java-chassis-0.x-plugin/src/test/java/org/apache/skywalking/apm/plugin/servicecomb/InvocationInterceptorTest.java b/apm-sniffer/apm-sdk-plugin/servicecomb-plugin/servicecomb-java-chassis-0.x-plugin/src/test/java/org/apache/skywalking/apm/plugin/servicecomb/InvocationInterceptorTest.java index f93eea237..32c64efbf 100644 --- a/apm-sniffer/apm-sdk-plugin/servicecomb-plugin/servicecomb-java-chassis-0.x-plugin/src/test/java/org/apache/skywalking/apm/plugin/servicecomb/InvocationInterceptorTest.java +++ b/apm-sniffer/apm-sdk-plugin/servicecomb-plugin/servicecomb-java-chassis-0.x-plugin/src/test/java/org/apache/skywalking/apm/plugin/servicecomb/InvocationInterceptorTest.java @@ -98,7 +98,7 @@ public class InvocationInterceptorTest { when(operationMeta.getSchemaMeta()).thenReturn(schemaMeta); when(endpoint.getAddress()).thenReturn("0.0.0.0:7777"); when(enhancedInstance.getEndpoint()).thenReturn(endpoint); - when(enhancedInstance.getInvocationQualifiedName()).thenReturn("productorTest"); + when(enhancedInstance.getMicroserviceQualifiedName()).thenReturn("productorTest"); when(operationMeta.getOperationPath()).thenReturn("/bmi"); when(enhancedInstance.getOperationMeta()).thenReturn(operationMeta); when(enhancedInstance.getStatus()).thenReturn(statusType); diff --git a/apm-sniffer/apm-sdk-plugin/servicecomb-plugin/servicecomb-java-chassis-0.x-plugin/src/test/java/org/apache/skywalking/apm/plugin/servicecomb/NextInterceptorTest.java b/apm-sniffer/apm-sdk-plugin/servicecomb-plugin/servicecomb-java-chassis-0.x-plugin/src/test/java/org/apache/skywalking/apm/plugin/servicecomb/NextInterceptorTest.java index 80af9f20b..e0b012838 100644 --- a/apm-sniffer/apm-sdk-plugin/servicecomb-plugin/servicecomb-java-chassis-0.x-plugin/src/test/java/org/apache/skywalking/apm/plugin/servicecomb/NextInterceptorTest.java +++ b/apm-sniffer/apm-sdk-plugin/servicecomb-plugin/servicecomb-java-chassis-0.x-plugin/src/test/java/org/apache/skywalking/apm/plugin/servicecomb/NextInterceptorTest.java @@ -99,7 +99,7 @@ public class NextInterceptorTest { when(operationMeta.getSchemaMeta()).thenReturn(schemaMeta); when(endpoint.getAddress()).thenReturn("0.0.0.0:7777"); when(enhancedInstance.getEndpoint()).thenReturn(endpoint); - when(enhancedInstance.getInvocationQualifiedName()).thenReturn("consumerTest"); + when(enhancedInstance.getMicroserviceQualifiedName()).thenReturn("consumerTest"); when(operationMeta.getOperationPath()).thenReturn("/bmi"); when(enhancedInstance.getOperationMeta()).thenReturn(operationMeta); when(enhancedInstance.getStatus()).thenReturn(statusType);